Changed all tables names to lowercase
diff --git a/apidAnalytics_suite_test.go b/apidAnalytics_suite_test.go index 8c979cb..d2d97e6 100644 --- a/apidAnalytics_suite_test.go +++ b/apidAnalytics_suite_test.go
@@ -217,7 +217,7 @@ txn, err := db.Begin() Expect(err).ShouldNot(HaveOccurred()) - txn.Exec("INSERT INTO kms_APP_CREDENTIAL_APIPRODUCT_MAPPER (tenant_id,"+ + txn.Exec("INSERT INTO kms_app_credential_apiproduct_mapper (tenant_id,"+ " appcred_id, app_id, apiprdt_id, status, _change_selector) "+ "VALUES"+ "($1,$2,$3,$4,$5,$6)", @@ -229,7 +229,7 @@ "12345", ) - txn.Exec("INSERT INTO kms_APP (id, tenant_id, name, developer_id) "+ + txn.Exec("INSERT INTO kms_app (id, tenant_id, name, developer_id) "+ "VALUES"+ "($1,$2,$3,$4)", "testappid", @@ -238,7 +238,7 @@ "testdeveloperid", ) - txn.Exec("INSERT INTO kms_API_PRODUCT (id, tenant_id, name) "+ + txn.Exec("INSERT INTO kms_api_product (id, tenant_id, name) "+ "VALUES"+ "($1,$2,$3)", "testproductid", @@ -246,7 +246,7 @@ "testproduct", ) - txn.Exec("INSERT INTO kms_DEVELOPER (id, tenant_id, username, email) "+ + txn.Exec("INSERT INTO kms_developer (id, tenant_id, username, email) "+ "VALUES"+ "($1,$2,$3,$4)", "testdeveloperid", @@ -255,7 +255,7 @@ "testdeveloper@test.com", ) - txn.Exec("INSERT INTO edgex_DATA_SCOPE (id, _change_selector, "+ + txn.Exec("INSERT INTO edgex_data_scope (id, _change_selector, "+ "apid_cluster_id, scope, org, env) "+ "VALUES"+ "($1,$2,$3,$4,$5,$6)",
diff --git a/common_helper.go b/common_helper.go index 803c649..b8a2696 100644 --- a/common_helper.go +++ b/common_helper.go
@@ -135,7 +135,7 @@ var org, env, tenantId string db := getDB() - error := db.QueryRow("SELECT env, org, scope FROM edgex_DATA_SCOPE"+ + error := db.QueryRow("SELECT env, org, scope FROM edgex_data_scope"+ " where id = ?", scopeuuid).Scan(&env, &org, &tenantId) switch { @@ -165,10 +165,10 @@ db := getDB() sSql := "SELECT ap.name, a.name, d.username, d.email " + - "FROM kms_APP_CREDENTIAL_APIPRODUCT_MAPPER as mp " + - "INNER JOIN kms_API_PRODUCT as ap ON ap.id = mp.apiprdt_id " + - "INNER JOIN kms_APP AS a ON a.id = mp.app_id " + - "INNER JOIN kms_DEVELOPER as d ON d.id = a.developer_id " + + "FROM kms_app_credential_apiproduct_mapper as mp " + + "INNER JOIN kms_api_product as ap ON ap.id = mp.apiprdt_id " + + "INNER JOIN kms_app AS a ON a.id = mp.app_id " + + "INNER JOIN kms_developer as d ON d.id = a.developer_id " + "where mp.tenant_id = ? and mp.appcred_id = ?;" error := db.QueryRow(sSql, tenantId, apiKey). Scan(&apiProduct, &developerApp,
diff --git a/listener_test.go b/listener_test.go index d9918e6..b14fd9f 100644 --- a/listener_test.go +++ b/listener_test.go
@@ -86,7 +86,7 @@ It("insert/delete event should add/remove to/from cache if usecaching is true", func() { txn, err := getDB().Begin() Expect(err).ShouldNot(HaveOccurred()) - txn.Exec("INSERT INTO edgex_DATA_SCOPE (id, _change_selector, apid_cluster_id, scope, org, env) "+ + txn.Exec("INSERT INTO edgex_data_scope (id, _change_selector, apid_cluster_id, scope, org, env) "+ "VALUES"+ "($1,$2,$3,$4,$5,$6)", "i2", @@ -128,7 +128,7 @@ txn, err = getDB().Begin() Expect(err).ShouldNot(HaveOccurred()) - txn.Exec("DELETE FROM edgex_DATA_SCOPE where id = 'i2'") + txn.Exec("DELETE FROM edgex_data_scope where id = 'i2'") txn.Commit() delete := common.ChangeList{