[ISSUE-71761531] Add KMS indexes

diff --git a/common/data.go b/common/data.go
index f7c9ba6..8f409ea 100644
--- a/common/data.go
+++ b/common/data.go

@@ -117,6 +117,44 @@
 	return
 }
 
+func AddIndexes(version string) error {
+	db, err := services.Data().DBVersion(version)
+	if err != nil {
+		log.Errorf("Unable to access database: %v", err)
+		return err
+	}
+	log.Debugf("adding indexes to sqlite file")
+	tx, err := db.Begin()
+	if err != nil {
+		log.Errorf("AddIndexes: Unable to get DB tx Err: {%v}", err)
+		return err
+	}
+	defer tx.Rollback()
+	_, err = tx.Exec(`
+	CREATE INDEX IF NOT EXISTS mp_appcred_id on KMS_APP_CREDENTIAL_APIPRODUCT_MAPPER (appcred_id);
+	CREATE INDEX IF NOT EXISTS mp_app_id on KMS_APP_CREDENTIAL_APIPRODUCT_MAPPER (app_id);
+	CREATE INDEX IF NOT EXISTS mp_apiprdt_id on KMS_APP_CREDENTIAL_APIPRODUCT_MAPPER (apiprdt_id);
+	CREATE INDEX IF NOT EXISTS app_name on KMS_APP (name);
+	CREATE INDEX IF NOT EXISTS app_company_id on KMS_APP (company_id);
+	CREATE INDEX IF NOT EXISTS app_developer_id on KMS_APP (developer_id);
+	CREATE INDEX IF NOT EXISTS dev_email on KMS_DEVELOPER (email);
+	CREATE INDEX IF NOT EXISTS com_name on KMS_COMPANY (name);
+	CREATE INDEX IF NOT EXISTS com_dev_com_id on KMS_COMPANY_DEVELOPER (company_id);
+	CREATE INDEX IF NOT EXISTS com_dev_dev_id on KMS_COMPANY_DEVELOPER (developer_id);
+	CREATE INDEX IF NOT EXISTS cred_app_id on KMS_APP_CREDENTIAL (app_id);
+	CREATE INDEX IF NOT EXISTS org_tenant_id on KMS_ORGANIZATION (tenant_id);
+	CREATE INDEX IF NOT EXISTS org_name on KMS_ORGANIZATION (name);
+	`)
+	if err != nil {
+		log.Errorf("AddIndexes: Tx Exec Err: {%v}", err)
+		return err
+	}
+	if err = tx.Commit(); err != nil {
+		log.Errorf("Commit error in AddIndexes: %v", err)
+	}
+	return err
+}
+
 func JsonToStringArray(fjson string) []string {
 	var array []string
 	if err := json.Unmarshal([]byte(fjson), &array); err == nil {

diff --git a/common/data_test.go b/common/data_test.go
index 7070890..0a29c46 100644
--- a/common/data_test.go
+++ b/common/data_test.go

@@ -61,6 +61,10 @@
 			Expect(orgs).Should(Equal([]string{"apid-haoming", "apid-test"}))
 		})
 
+		It("Add indexes", func() {
+			Expect(AddIndexes(testDbMan.GetDbVersion())).Should(Succeed())
+		})
+
 	})
 
 	Context("Validate common.JsonToStringArray", func() {

diff --git a/common/data_test.sql b/common/data_test.sql
index 1b5349b..6681d40 100644
--- a/common/data_test.sql
+++ b/common/data_test.sql

@@ -29,4 +29,11 @@
 CREATE TABLE edgex_data_scope (id text,apid_cluster_id text,scope text,org text,env text,created blob,created_by text,updated blob,updated_by text,_change_selector text,org_scope text,env_scope text, primary key (id));
 INSERT INTO "edgex_data_scope" VALUES('cc066263-6355-416d-9d59-7f3135d64953','543230f1-8c41-4bf5-94a3-f10c104ff5d4','155211e9','apid-haoming','test','2017-08-27 22:53:33.859+00:00','foobar@google.com','2017-08-27 22:53:33.859+00:00','foobar@google.com','543230f1-8c41-4bf5-94a3-f10c104ff5d4','12344caf-40d6-4ecb-8149-ed32d04184b2','1234203e-ba88-4cd5-967d-4caa88f64909');
 INSERT INTO "edgex_data_scope" VALUES('08c81eeb-57ec-43fe-8fed-cdff5494406f','123430f1-8c41-4bf5-94a3-f10c104ff5d4','165211e9','apid-test','prod','2017-08-29 02:39:34.093+00:00','foobar@google.com','2017-08-29 02:39:34.093+00:00','foobar@google.com','123430f1-8c41-4bf5-94a3-f10c104ff5d4','43214caf-40d6-4ecb-8149-ed32d04184b2','43211cae-f2a6-4663-9f36-eb17d76e6c32');
+CREATE TABLE kms_company_developer (tenant_id text,company_id text,developer_id text,roles text,created_at blob,created_by text,updated_at blob,updated_by text,_change_selector text, primary key (tenant_id,company_id,developer_id));
+CREATE TABLE kms_developer (id text,tenant_id text,username text,first_name text,last_name text,password text,email text,status text,encrypted_password text,salt text,created_at blob,created_by text,updated_at blob,updated_by text,_change_selector text, primary key (id,tenant_id));
+CREATE TABLE kms_api_product (id text,tenant_id text,name text,display_name text,description text,api_resources text,approval_type text,scopes text,proxies text,environments text,quota text,quota_time_unit text,quota_interval integer,created_at blob,created_by text,updated_at blob,updated_by text,_change_selector text, primary key (id,tenant_id));
+CREATE TABLE kms_app (id text,tenant_id text,name text,display_name text,access_type text,callback_url text,status text,app_family text,company_id text,developer_id text,parent_id text,type text,created_at blob,created_by text,updated_at blob,updated_by text,_change_selector text, primary key (id,tenant_id));
+CREATE TABLE kms_app_credential_apiproduct_mapper (tenant_id text,appcred_id text,app_id text,apiprdt_id text,status text,_change_selector text, primary key (tenant_id,appcred_id,app_id,apiprdt_id));
+CREATE TABLE kms_company (id text,tenant_id text,name text,display_name text,status text,created_at blob,created_by text,updated_at blob,updated_by text,_change_selector text, primary key (id,tenant_id));
+CREATE TABLE kms_app_credential (id text,tenant_id text,consumer_secret text,app_id text,method_type text,status text,issued_at blob,expires_at blob,app_status text,scopes text,created_at blob,created_by text,updated_at blob,updated_by text,_change_selector text, primary key (id,tenant_id));
 COMMIT;

diff --git a/listener.go b/listener.go
index 4253cfc..2c4862a 100644
--- a/listener.go
+++ b/listener.go

@@ -44,6 +44,10 @@
 	for _, dbMan := range h.dbMans {
 		dbMan.SetDbVersion(snapshot.SnapshotInfo)
 	}
+	// add indexes
+	if err := common.AddIndexes(snapshot.SnapshotInfo); err != nil {
+		log.Errorf("Failed to add KMS indexes: %v", err)
+	}
 	// retrieve encryption keys
 	orgs, err := h.dbMans[0].GetOrgs()
 	if err != nil {