Update GetRecordSchemas function to avoid making new query when previ…

…ous query cursor is not yet closed.

Problem only happen when the queries are run in the same transaction, we don’t have db transaction in v1
schema create handler. So only apply this fix to next.
Related issue: lib/pq#635

pkg/record/dependency/record/pq/schema.go

@@ -158,6 +158,7 @@ func (s *recordStore) GetRecordSchemas() (map[string]record.Schema, error) {
 		return nil, err
 	}
 
+	tables := []string{}
 	result := map[string]record.Schema{}
 	for rows.Next() {
 		var recordTable string
@@ -166,7 +167,10 @@ func (s *recordStore) GetRecordSchemas() (map[string]record.Schema, error) {
 		}
 
 		s.logger.Debugf("%s\n", recordTable)
+		tables = append(tables, recordTable)
+	}
 
+	for _, recordTable := range tables {
 		recordType := strings.TrimPrefix(recordTable, "_record__")
 		schema, err := s.GetSchema(recordType)
 		if err != nil {