全量数据同步添加字段名

zhangzengfei

2023-10-30 70a2183a6f1c10614c0d0efe32147cad5e635060

 serf/sqlite.go

@@ -48,13 +48,16 @@
         }

         var columnNames []string
         var columnValues []string
         for _, col := range tDescArr {
            columnNames = append(columnNames, fmt.Sprintf(`'||quote("%s")||'`, col.Name))
            columnNames = append(columnNames, col.Name)
            columnValues = append(columnValues, fmt.Sprintf(`'||quote("%s")||'`, col.Name))
         }

         tSql = fmt.Sprintf(`SELECT 'INSERT INTO "%s" VALUES(%s)' as sql FROM "%s";`,
         tSql = fmt.Sprintf(`SELECT 'INSERT INTO "%s" (%s) VALUES(%s)' as sql FROM "%s";`,
            table,
            strings.Join(columnNames, ","),
            strings.Join(columnValues, ","),
            table)
         //fmt.Println("tSql:", tSql)