【TcaplusDB知识库】TDR表GOSDK示例代码-插入数据

使用工具TdrCodeGen将​​service_info.xml​​转为go代码

func insertExample() {

//创建insert请求

req, err := client.NewRequest(ZoneId, TableName, cmd.TcaplusApiInsertReq)

if err != nil {

fmt.Printf("NewRequest TcaplusApiInsertReq failed %v\n", err.Error())

return

}

fmt.Printf("insertExample NewRequest TcaplusApiInsertReq finish\n")

rec, err := req.AddRecord(0)

if err != nil {

fmt.Printf("AddRecord failed %v\n", err.Error())

return

}

fmt.Printf("insertExample AddRecord finish\n")

//申请tdr结构体并赋值，最好调用tdr pkg的NewXXX函数，会将成员初始化为tdr定义的tdr默认值，

// 不要自己new，自己new，某些结构体未初始化，存在panic的风险

data := service_info.NewService_Info()

data.Gameid = "dev"

data.Envdata = "oa"

data.Name = "com"

data.Filterdata = time.Now().Format("2006-01-02T15:04:05.000000Z")

data.Updatetime = uint64(time.Now().UnixNano())

data.Inst_Max_Num = 2

data.Inst_Min_Num = 3

//数组类型为slice需要准确赋值长度，与refer保持一致

route := "test"

data.Routeinfo_Len = uint32(len(route))

data.Routeinfo = []byte(route)

//将tdr的数据设置到请求的记录中

if err := rec.SetData(data); err != nil {

fmt.Printf("SetData failed %v\n", err.Error())

return

}

if resp, err := client.Do(req, time.Duration(2*time.Second)); err != nil {

fmt.Printf("recv err %s\n", err.Error())

return

} else {

tcapluserr := resp.GetResult()

if tcapluserr != 0 {

fmt.Printf("response ret errCode: %d, errMsg: %s", tcapluserr, terror.GetErrMsg(tcapluserr))

return

}

//获取同步请求Seq

fmt.Printf("request Seq %d\n", req.GetSeq())

//获取回应消息的序列号

fmt.Printf("respond seq: %d \n", resp.GetSeq())

}

}

TcaplusDB是腾讯出品的分布式NoSQL数据库，存储和调度的代码完全自研。具备缓存+落地融合架构、PB级存储、毫秒级时延、无损水平扩展和复杂数据结构等特性。同时具备丰富的生态、便捷的迁移、极低的运维成本和五个九高可用等特点。客户覆盖游戏、互联网、政务、金融、制造和物联网等领域。