MCPcopy Create free account
hub / github.com/featureform/featureform / tableExists

Method tableExists

provider/sql.go:142–171  ·  view source on GitHub ↗
(id ResourceID)

Source from the content-addressed store, hash-verified

140}
141
142func (store *sqlOfflineStore) tableExists(id ResourceID) (bool, error) {
143 n := -1
144 var tableName string
145 var err error
146 if id.check(Feature, Label) == nil {
147 tableName, err = store.getResourceTableName(id)
148 } else if id.check(TrainingSet) == nil {
149 tableName, err = store.getTrainingSetName(id)
150 } else if id.check(Primary) == nil || id.check(Transformation) == nil {
151 tableName, err = GetPrimaryTableName(id)
152 }
153 if err != nil {
154 return false, fmt.Errorf("type check: %v: %v", id, err)
155 }
156 query := store.query.tableExists()
157 err = store.db.QueryRow(query, tableName).Scan(&n)
158 if n > 0 && err == nil {
159 return true, nil
160 } else if err != nil {
161 return false, fmt.Errorf("table exists check: %v", err)
162 }
163 query = store.query.viewExists()
164 err = store.db.QueryRow(query, tableName).Scan(&n)
165 if n > 0 && err == nil {
166 return true, nil
167 } else if err != nil {
168 return false, fmt.Errorf("view exists check: %v", err)
169 }
170 return false, nil
171}
172
173func (store *sqlOfflineStore) AsOfflineStore() (OfflineStore, error) {
174 return store, nil

Callers 8

CreatePrimaryTableMethod · 0.95
GetPrimaryTableMethod · 0.95
CreateResourceTableMethod · 0.95
ResourceLocationMethod · 0.95
GetTrainingSetMethod · 0.95
getsqlResourceTableMethod · 0.95

Calls 6

getResourceTableNameMethod · 0.95
getTrainingSetNameMethod · 0.95
GetPrimaryTableNameFunction · 0.85
tableExistsMethod · 0.65
viewExistsMethod · 0.65
checkMethod · 0.45

Tested by

no test coverage detected