in example/session_pool/session_pool_example.go [257:279]
func insertAlignedRecord() {
var (
deviceId = "root.al1.dev1"
measurements = []string{"status"}
values = []interface{}{"123"}
dataTypes = []client.TSDataType{client.TEXT}
timestamp int64 = 12
)
session, err := sessionPool.GetSession()
defer sessionPool.PutBack(session)
if err == nil {
checkError(session.InsertAlignedRecord(deviceId, measurements, dataTypes, values, timestamp))
sessionDataSet, err := session.ExecuteStatement("show devices")
if err == nil {
printDataSet0(sessionDataSet)
sessionDataSet.Close()
} else {
log.Println(err)
}
fmt.Println()
}
}