【TcaplusDB知识库】Tcaplus Go SDK手册（二）
4 接口列表
支持命令：//Generic表插入请求TcaplusApiInsertReq = 0x0001//Generic表替换/插入请求TcaplusApiReplaceReq = 0x0003//Generic表增量更新请求TcaplusApiIncreaseReq = 0x0005//Generic表单条查询请求TcaplusApiGetReq = 0x0007//Generic表删除请求TcaplusApiDeleteReq = 0x0009//Generic表删除应答TcaplusApiDeleteRes = 0x000a//Generic表更新请求TcaplusApiUpdateReq = 0x001d//List表查询所有元素请求TcaplusApiListGetAllReq = 0x000b//Generic表批量查询请求TcaplusApiBatchGetReq = 0x0017//Generic表按索引查询请求TcaplusApiGetByPartkeyReq = 0x0019//Generic表按索引更新请求TcaplusApiUpdateByPartkeyReq = 0x004d//Generic表按索引删除请求TcaplusApiDeleteByPartkeyReq = 0x004f4.1 Client接口
4.1.1 创建tcaplus client
/**@brief 创建一个tcaplus api客户端@retval 返回客户端指针**/func NewClient() *Client4.1.2 日志配置接口
创建client之后，立刻调用
/**@brief 设置API日志配置文件全路径log.conf(json格式，example下有示例)，请在client.Dial之前调用@param [IN] cfgPath 日志配置文件全路径log.conf@retval 错误码@note Api日志默认使用的zap，用户也可自行实现日志接口logger.LogInterface，调用SetLogger进行设置**/func (c *Client) SetLogCfg(cfgPath string) error/**@brief 自定义API日志接口,用户实现logger.LogInterface日志接口，日志将打印到用户的日志接口中，请在client.Dial之前调用@param [IN] handle logger.LogInterface类型的日志接口@retval 错误码**/func (c *Client) SetLogger(handle logger.LogInterface)4.1.3 连接tcaplus接口
/**@brief 连接tcaplue函数@param [IN] appId appId，在网站注册相应服务以后，你可以得到该appId@param [IN] zoneList 需要操作表的区服ID列表，操作的表在多个不同的zone，填zoneId列表；操作的表在一个zone，zone列表填一个zoneId@param [IN] signature 签名/密码，在网站注册相应服务以后，你可以得到该字符串@param [IN] dirUrl 目录服务器的url，形如"tcp://172.25.40.181:10600"@param [IN] timeout second, 连接所有表对应的tcaplus proxy服务器。若所有的proxy连通且鉴权通过，则立即返回成功；若到达超时时间，只要有一个proxy连通且鉴权通过，也会返回成功；否则返回超时错误。@retval 错误码**/func (c *Client) Dial(appId uint64, zoneList []uint32, dirUrl string, signature string, timeout uint32) error4.1.4 创建tcaplus请求
/**@brief 创建指定分区指定表的tcaplus请求@param [IN] zoneId 区服ID@param [IN] tableName 表名@param [IN] cmd 命令字(cmd包中cmd.TcaplusApiGetReq等)@retval request.TcaplusRequest tcaplus请求@retval error 错误码*/func (c *Client) NewRequest(zoneId uint32, tableName string, cmd int) (request.TcaplusRequest, error)4.1.5 发送tcaplus请求
/**@brief 发送tcaplus请求@param [IN] req tcaplus请求@retval error 错误码*/func (c *Client) SendRequest(req request.TcaplusRequest) error4.1.6 异步接收tcaplus响应
/**@brief 异步接收tcaplus响应@retval response.TcaplusResponse tcaplus响应@retval error 错误码error nil，response nil 成功但当前无响应消息error nil, response 非nil，成功获取响应消息error 非nil，接收响应出错*/func (c *Client) RecvResponse() (response.TcaplusResponse, error)4.1.7 发送tcaplus同步请求并接受响应
/**@brief 发送tcaplus同步请求并接受响应@param [IN] req tcaplus请求@param [IN] timeout 超时时间@retval response.TcaplusResponse tcaplus响应@retval error 错误码error nil，response nil 成功但当前无响应消息error nil, response 非nil，成功获取响应消息error 非nil，接收响应出错**/func (c *Client) Do(req request.TcaplusRequest, timeout time.Duration) (response.TcaplusResponse, error)4.2 TcaplusRequest接口
4.2.1 添加记录
/**@brief 向请求中添加一条记录。@param [IN] index 用于List操作(目前不支持)，通常>=0，表示该Record在所属List中的Index；对于Generic操作，index无意义，设0即可@retval record.Record 返回记录指针@retval error 错误码**/AddRecord(index int32) (*record.Record, error)4.2.2 设置请求异步ID
/**@brief 设置请求的异步事务ID，api会将其值不变地通过对应的响应消息带回来@param [IN] asyncId 请求对应的异步事务ID**/SetAsyncId(id uint64)4.2.3 设置版本校验规则
/**@brief 设置记录版本的检查类型，用于乐观锁@param [IN] type 版本检测类型，取值可以为(policy包中):CheckDataVersionAutoIncrease: 表示检测记录版本号，只有当record.SetVersion函数传入的参数version的值>0,并且版本号与服务器端的版本号相同时，请求才会成功同时在服务器端该版本号会自增1；如果record.SetVersion的version <=0，则仍然表示不关心版本号NoCheckDataVersionOverwrite: 表示不检测记录版本号。当record.SetVersion函数传入的参数version的值>0,覆盖服务端的版本号；如果record.SetVersion的version <=0，则仍然表示不关心版本号NoCheckDataVersionAutoIncrease: 表示不检测记录版本号，将服务器端的数据记录版本号自增1，若服务器端新写入数据记录则新写入的数据记录的版本号为1@retval error 错误码@note 此函数适合Replace, Update操作**/SetVersionPolicy(p uint8) error4.2.4 设置响应标志
/**@brief 设置响应标志。主要用于Generic表的insert、replace、update、delete操作。@param [IN] flag 请求标志:0表示: 只需返回操作执行成功与否1表示: 操作成功，响应返回与请求字段一致2表示: 操作成功，响应返回变更记录的所有字段最新数据3表示: 操作成功，响应返回变更记录的所有字段旧数据@retval error 错误码**/SetResultFlag(flag int) error4.2.5 部分字段查询和更新
/**@brief 设置需要查询或更新的Value字段名称列表，即部分Value字段查询和更新，可用于get、replace、update操作。@param [IN] valueNameList 需要查询或更新的字段名称列表@retval error 错误码@note 在使用该函数设置字段名时，字段名只能包含value字段名，不能包含key字段名；对于数组类型的字段，refer字段和数组字段要同时设置或者同时不设置，否则容易数据错乱**/SetFieldNames(valueNameList []string) error4.2.6 设置用户缓存
/**@brief 设置用户缓存，响应消息将携带返回@param [IN] userBuffer 用户缓存@retval error 错误码**/SetUserBuff(userBuffer []byte) error4.3 Record接口
4.3.1 SetKey/SetValue和GetKey/GetValue接口
通过KV接口，对记录进行赋值(请求消息)和获取(响应消息)
/**@brief key字段内容设置@param [in] name 字段名称，最大长度32@param [in] data 字段内容@retval error 错误码*/func (r *Record) SetKeyInt8(name string, data int8) errorfunc (r *Record) SetKeyInt16(name string, data int16) errorfunc (r *Record) SetKeyInt32(name string, data int32) errorfunc (r *Record) SetKeyInt64(name string, data int64) errorfunc (r *Record) SetKeyFloat32(name string, data float32) errorfunc (r *Record) SetKeyFloat64(name string, data float64) errorfunc (r *Record) SetKeyStr(name string, data string) errorfunc (r *Record) SetKeyBlob(name string, data []byte) error/**@brief value字段内容设置@param [in] name 字段名称，最大长度32@param [in] data 字段内容@retval error 错误码*/func (r *Record) SetValueInt8(name string, data int8) errorfunc (r *Record) SetValueInt16(name string, data int16) errorfunc (r *Record) SetValueInt32(name string, data int32) errorfunc (r *Record) SetValueInt64(name string, data int64) errorfunc (r *Record) SetValueFloat32(name string, data float32) errorfunc (r *Record) SetValueFloat64(name string, data float64) errorfunc (r *Record) SetValueStr(name string, data string) errorfunc (r *Record) SetValueBlob(name string, data []byte) error/**@brief key字段内容获取@param [in] name 字段名称，最大长度32@retval data 字段内容@retval error 错误码*/func (r *Record) GetKeyInt8(name string) (int8, error)func (r *Record) GetKeyInt16(name string) (int16, error)func (r *Record) GetKeyInt32(name string) (int32, error)func (r *Record) GetKeyInt64(name string) (int64, error)func (r *Record) GetKeyFloat32(name string) (float32, error)func (r *Record) GetKeyFloat64(name string) (float64, error)func (r *Record) GetKeyStr(name string) (string, error)func (r *Record) GetKeyBlob(name string) ([]byte, error)/**@brief value字段内容获取@param [in] name 字段名称，最大长度32@retval data 字段内容@retval error 错误码*/func (r *Record) GetValueInt8(name string) (int8, error)func (r *Record) GetValueInt16(name string) (int16, error)func (r *Record) GetValueInt32(name string) (int32, error)func (r *Record) GetValueInt64(name string) (int64, error)func (r *Record) GetValueFloat32(name string) (float32, error)func (r *Record) GetValueFloat64(name string) (float64, error)func (r *Record) GetValueStr(name string) (string, error)func (r *Record) GetValueBlob(name string) ([]byte, error)4.3.2 SetData和GetData接口
通过TDR结构体，对记录进行赋值(请求消息)和获取(响应消息)
/**@brief 基于TDR描述设置record数据@param [IN] data 基于TDR描述record接口数据，tdr的xml通过工具生成的go结构体，包含的TdrTableSt接口的一系列方法@retval error 错误码*/func (r *Record) SetData(data TdrTableSt) error/**@brief 基于TDR描述读取record数据@param [IN] data 基于TDR描述record接口数据，tdr的xml通过工具生成的go结构体，包含的TdrTableSt接口的一系列方法@retval error 错误码**/func (r *Record) GetData(data TdrTableSt) error4.3.3 设置记录版本号
/**@brief 设置记录版本号@param [IN] v 数据记录的版本号: <=0 表示不关注版本号不关心版本号。具体含义如下。当CHECKDATAVERSION_AUTOINCREASE时: 表示检测记录版本号。如果Version的值<=0,则仍然表示不关心版本号不关注版本号；如果Version的值>0，那么只有当该版本号与服务器端的版本号相同时，Replace, Update, Increase, ListAddAfter, ListDelete, ListReplace, ListDeleteBatch操作才会成功同时在服务器端该版本号会自增1。当NOCHECKDATAVERSION_OVERWRITE时: 表示不检测记录版本号。如果Version的值<=0,则会把版本号1写入服务端的数据记录版本号(服务器端成功写入的数据记录的版本号最少为1)；如果Version的值>0，那么会把该版本号写入服务端的数据记录版本号。当NOCHECKDATAVERSION_AUTOINCREASE时: 表示不检测记录版本号，将服务器端的数据记录版本号自增1，若服务器端新写入数据记录则新写入的数据记录的版本号为1。**/func (r *Record) SetVersion(v int32)4.3.4 获取记录版本号
/**@brief 获取记录版本号@retval 记录版本号**/func (r *Record) GetVersion() int324.4 TcaplusResponse接口
4.4.1 获取响应结果
/*@brief 获取响应结果@retval int tcaplus api自定义错误码。 0，表示请求成功；非0,有错误码，可从terror.GetErrMsg(int)得到错误消息*/GetResult() int4.4.2 获取表名
/*@brief 获取响应表名@retval string 响应消息对应的表名称*/GetTableName() string4.4.3 获取appId
/*@brief 获取响应appId@retval uint64 响应消息对应的appId*/GetAppId() uint644.4.4 获取zoneId
/*@brief 获取响应zoneId@retval uint32 响应消息对应的zoneId*/GetZoneId() uint324.4.5 获取响应命令字
/*@brief 获取响应命令@retval int 响应消息命令字，cmd包中的响应命令字*/GetCmd() int4.4.6 获取响应异步ID
/*@brief 获取响应异步id，和请求对应@retval uint64 响应消息对应的异步id和请求对应*/GetAsyncId() uint644.4.7 获取响应中记录数
/*@brief 获取本响应中结果记录条数@retval int 响应中结果记录条数*/GetRecordCount() int4.4.8 获取响应中一条记录
/*@brief 从结果中获取一条记录@retval *record.Record 记录指针@retval error 错误码*/FetchRecord() (*record.Record, error)4.4.9 获取响应中用户缓存信息
/**@brief 获取响应消息中的用户缓存信息@retval []byte 用户缓存二进制，和请求消息中的buffer内容一致*/GetUserBuffer() []byte4.4.10 获取响应中的序列号
/**@brief 获取响应消息中的序列号**/GetSeq() int32
TcaplusDB是腾讯出品的分布式NoSQL数据库，存储和调度的代码完全自研。具备缓存+落地融合架构、PB级存储、毫秒级时延、无损水平扩展和复杂数据结构等特性。同时具备丰富的生态、便捷的迁移、极低的运维成本和五个九高可用等特点。客户覆盖游戏、互联网、政务、金融、制造和物联网等领域。
