全量数据同步添加字段名

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)