Following changes were done

1) Made data loader case insensitive for mysql & sql server

gateway/model/crud.go

@@ -121,6 +121,9 @@ const (
 	// SQLServer is the type used for MsSQL
 	SQLServer DBType = "sqlserver"
 
+	// DefaultValidate is used for default validation operation
+	DefaultValidate = "default"
+
 	// DefaultFetchLimit is the default value to be used as a limit to fetch rows/collection in each read query
 	DefaultFetchLimit = 1000
 )

gateway/model/graphql.go

@@ -11,8 +11,9 @@ type GraphQLRequest struct {
 
 // ReadRequestKey is the key type for the dataloader
 type ReadRequestKey struct {
-	DBType     string
+	DBAlias    string
 	Col        string
+	DBType     string
 	HasOptions bool
 	Req        ReadRequest
 	ReqParams  RequestParams

gateway/modules/crud/bolt/delete.go

@@ -31,7 +31,7 @@ func (b *Bolt) Delete(ctx context.Context, col string, req *model.DeleteRequest)
 					return helpers.Logger.LogError(helpers.GetRequestID(ctx), "Unable to unmarshal data of bbolt db", err, nil)
 				}
 				// if valid then delete
-				if utils.Validate(req.Find, result) {
+				if utils.Validate(string(model.EmbeddedDB), req.Find, result) {
 					// delete data
 					if err := bucket.Delete(k); err != nil {
 						return helpers.Logger.LogError(helpers.GetRequestID(ctx), "Unable to delete bbolt key", err, nil)

gateway/modules/crud/bolt/read.go

@@ -40,7 +40,7 @@ func (b *Bolt) Read(ctx context.Context, col string, req *model.ReadRequest) (in
 				if err := json.Unmarshal(v, &result); err != nil {
 					return helpers.Logger.LogError(helpers.GetRequestID(ctx), "Unable to unmarshal while reading from bbolt db", err, nil)
 				}
-				if utils.Validate(req.Find, result) {
+				if utils.Validate(string(model.EmbeddedDB), req.Find, result) {
 					if req.Options.Debug {
 						result["_dbFetchTs"] = time.Now().Format(time.RFC3339Nano)
 					}

gateway/modules/crud/bolt/update.go

@@ -31,7 +31,7 @@ func (b *Bolt) Update(ctx context.Context, col string, req *model.UpdateRequest)
 					return helpers.Logger.LogError(helpers.GetRequestID(ctx), "Unable to unmarshal data read from bbbolt db", err, nil)
 				}
 				// if valid then update
-				if utils.Validate(req.Find, currentObj) {
+				if utils.Validate(string(model.EmbeddedDB), req.Find, currentObj) {
 					objToSet, ok := req.Update["$set"].(map[string]interface{})
 					if !ok {
 						return helpers.Logger.LogError(helpers.GetRequestID(ctx), "Unable to update in bbolt - $set db operator not found or the operator value is not map", nil, nil)

gateway/modules/crud/dataloader.go

@@ -20,6 +20,7 @@ type resultsHolder struct {
 type meta struct {
 	whereClause map[string]interface{}
 	op          string
+	dbType      string
 }
 
 type queryResult struct {
@@ -51,7 +52,7 @@ func (holder *resultsHolder) getWhereClauses() []interface{} {
 	return arr
 }
 
-func (holder *resultsHolder) addMeta(op string, whereClause map[string]interface{}, matchClause []map[string]interface{}) {
+func (holder *resultsHolder) addMeta(op, dbType string, whereClause map[string]interface{}, matchClause []map[string]interface{}) {
 	holder.Lock()
 	for i, where := range matchClause {
 		for k, v := range where {
@@ -61,7 +62,7 @@ func (holder *resultsHolder) addMeta(op string, whereClause map[string]interface
 			whereClause[k] = v
 		}
 	}
-	holder.metas = append(holder.metas, meta{whereClause: whereClause, op: op})
+	holder.metas = append(holder.metas, meta{whereClause: whereClause, op: op, dbType: dbType})
 	holder.Unlock()
 }
 
@@ -85,7 +86,7 @@ func (holder *resultsHolder) fillResults(metData *model.SQLMetaData, res []inter
 		isOperationTypeOne := meta.op == utils.One
 		docs := make([]interface{}, 0)
 		for _, doc := range res {
-			if utils.Validate(meta.whereClause, doc) {
+			if utils.Validate(meta.dbType, meta.whereClause, doc) {
 				docs = append(docs, doc)
 			}
 			if isOperationTypeOne {
@@ -160,7 +161,7 @@ func (m *Module) dataLoaderBatchFn(c context.Context, keys dataloader.Keys) []*d
 	for index, key := range keys {
 		req := key.(model.ReadRequestKey)
 
-		dbAlias = req.DBType
+		dbAlias = req.DBAlias
 		col = req.Col
 
 		// Execute query immediately if it has options
@@ -193,7 +194,7 @@ func (m *Module) dataLoaderBatchFn(c context.Context, keys dataloader.Keys) []*d
 		}
 
 		// Append the where clause to the list
-		holder.addMeta(req.Req.Operation, req.Req.Find, req.Req.MatchWhere)
+		holder.addMeta(req.Req.Operation, req.DBType, req.Req.Find, req.Req.MatchWhere)
 	}
 
 	// Wait for all results to be done

gateway/modules/crud/operations.go

@@ -65,7 +65,11 @@ func (m *Module) Read(ctx context.Context, dbAlias, col string, req *model.ReadR
 	}
 
 	if req.IsBatch {
-		key := model.ReadRequestKey{DBType: dbAlias, Col: col, HasOptions: req.Options.HasOptions, Req: *req, ReqParams: params}
+		dbType, err := m.GetDBType(dbAlias)
+		if err != nil {
+			return nil, nil, err
+		}
+		key := model.ReadRequestKey{DBType: dbType, DBAlias: dbAlias, Col: col, HasOptions: req.Options.HasOptions, Req: *req, ReqParams: params}
 		dataLoader, ok := m.getLoader(fmt.Sprintf("%s-%s-%s", m.project, dbAlias, col))
 		if !ok {
 			dataLoader = m.createLoader(fmt.Sprintf("%s-%s-%s", m.project, dbAlias, col))

gateway/modules/crud/sql/integration_raw_test.go

@@ -64,7 +64,7 @@ func TestSQL_CreateDatabaseIfNotExist(t *testing.T) {
 						v[colType.Name()] = string(value)
 					}
 				}
-				// mysqlTypeCheck(utils.DBType(*dbType), rowTypes, v)
+				// mysqlTypeCheck(utils.DBAlias(*dbType), rowTypes, v)
 				readResult = append(readResult, v)
 			}
 			if !reflect.DeepEqual(tt.want, readResult) {

gateway/modules/eventing/eventing_test.go

@@ -29,7 +29,7 @@ func TestModule_SetConfig(t *testing.T) {
 			schemaMockArgs: []mockArgs{},
 		},
 		{
-			name:    "DBType not mentioned",
+			name:    "DBAlias not mentioned",
 			m:       &Module{config: &config.Eventing{Enabled: true}},
 			args:    args{eventing: &config.EventingConfig{Enabled: true, DBAlias: ""}},
 			wantErr: true,

gateway/modules/realtime/routine.go

@@ -39,7 +39,7 @@ func (m *Module) helperSendFeed(ctx context.Context, data *model.FeedData) {
 				m.metrics.AddDBOperation(m.project, data.DBType, data.Group, 1, model.Read)
 
 			case utils.RealtimeInsert, utils.RealtimeUpdate:
-				if utils.Validate(query.whereObj, data.Payload) {
+				if utils.Validate(model.DefaultValidate, query.whereObj, data.Payload) {
 					_ = m.auth.PostProcessMethod(ctx, query.actions, dataPoint.Payload)
 					query.sendFeed(dataPoint)
 					m.metrics.AddDBOperation(m.project, data.DBType, data.Group, 1, model.Read)

gateway/modules/schema/creation.go

@@ -209,7 +209,6 @@ func (s *Schema) generateCreationQueries(ctx context.Context, dbAlias, tableName
 			continue
 		}
 		if arr := deep.Equal(fields.IndexTableProperties, cleanIndexMap(currentIndexMap[indexName].IndexTableProperties)); len(arr) > 0 {
-			fmt.Println("Array", arr)
 			batchedQueries = append(batchedQueries, s.removeIndex(dbType, dbAlias, logicalDBName, tableName, currentIndexMap[indexName].IndexName))
 			batchedQueries = append(batchedQueries, s.addIndex(dbType, dbAlias, logicalDBName, tableName, indexName, fields.IsIndexUnique, fields.IndexTableProperties))
 		}