package main
import "fmt"
// Point 点名
type Point struct {
PointID uint64 `json:"pointID"`
PathName string `json:"pathName"`
PointValue float32 `json:"pointValue"`
StoreTime string `json:"storeTime"`
}
func getSqlList(pointList []Point, groupSize int) []string {
const insertHeader string = "INSERT INTO `local_data`(`point_id`,`path_name`,`point_value`,`store_time`) VALUES"
sqlList := []string{}
sql := ""
for i := 0; i < len(pointList); i++ {
if i%groupSize == 0 {
if sql != "" {
//把上次拼接的SQL结果存储起来
sqlList = append(sqlList, sql)
}
//重置SQL
sql = insertHeader
}
if sql != insertHeader {
sql = sql + ","
}
sql = sql + fmt.Sprintf("(%d,"%s",%f,"%s")",
pointList[i].PointID,
pointList[i].PathName,
pointList[i].PointValue,
pointList[i].StoreTime)
}
//把最后一次生成的SQL存储起来
sqlList = append(sqlList, sql)
return sqlList
}
func main() {
points := []Point{
Point{1, "p1", 3.14, "2013-11-10 12:00:00"},
Point{2, "p1", 3.14, "2013-11-10 12"},
Point{3, "p1", 3.14, "2013-11-10 12"},
Point{4, "p1", 3.14, "2013-11-10 12"},
Point{5, "p1", 3.14, "2013-11-10 12"},
Point{6, "p1", 3.14, "2013-11-10 12"},
Point{7, "p1", 3.14, "2013-11-10 12"},
Point{8, "p1", 3.14, "2013-11-10 12"},
Point{9, "p1", 3.14, "2013-11-10 12"},
Point{10, "p1", 3.14, "2013-11-10 12"},
Point{11, "p1", 3.14, "2013-11-10 12"},
Point{12, "p1", 3.14, "2013-11-10 12"},
Point{13, "p1", 3.14, "2013-11-10 12"},
Point{14, "p1", 3.14, "2013-11-10 12"},
Point{15, "p1", 3.14, "2013-11-10 12"},
Point{16, "p1", 3.14, "2013-11-10 12"},
Point{17, "p1", 3.14, "2013-11-10 12"},
}
sqls := getSqlList(points, 5)
for _, s := range sqls {
fmt.Println(s)
}
}
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
