函数 | |
| int | rdb_soeput (int h, rec_soe psoe[], int nsize) |
| 写入SOE事件 | |
| int | rdb_soequery (int h, long long lts, unsigned int autokey, long long lte, const char *sexp, rdbcb_OnReadSoes pfun, void *pParam) |
| 查询SOE事件 | |
| int | rdb_soeupdate (int h, rec_soe psoe[], int nsize) |
| 更新SOE事件记录 | |
| int | rdb_soesubscription (int h, int flag) |
| 订阅SOE事件 | |
| int | rdb_soesubscription_setfun (int h, rdbcb_OnSscPutSoes fun, void *param) |
| 设置处理订阅的SOE事件处理回调函数 | |
| int | rdb_getoutlimit_snaps (int h, const char *station, void(*onread)(rec_tagval pvals[], int nitems, void *param), void *puserparam) |
| 读取当前越限标签快照 | |
| int | rdb_soesubscription_ex (int h, int flag, const char *station) |
| 订阅SOE的高级版,支持通过中心站订阅子站SOE | |
| int | rdb_soedelete (int h, const char *datetime_begin, unsigned int ukey_begin, const char *datetime_end, unsigned int ukey_end, int *pnumdelrecords) |
| 删除SOE记录, 双机热备时,只删除当前连接的实时库中数据。 | |
SOE事件的写入,查询相关接口函数。
| int rdb_getoutlimit_snaps | ( | int | h, |
| const char * | station, | ||
| void(*)(rec_tagval pvals[], int nitems, void *param) | onread, | ||
| void * | puserparam ) |
读取当前越限标签快照
| h | [in] rdb_create创建的句柄. |
| station | [in] 站名,nullptr表示主站 |
| onread | [in] 数据回调函数 |
| puserparam | 回调函数的参数,会原样填写到onread的param里。 |
| int rdb_soedelete | ( | int | h, |
| const char * | datetime_begin, | ||
| unsigned int | ukey_begin, | ||
| const char * | datetime_end, | ||
| unsigned int | ukey_end, | ||
| int * | pnumdelrecords ) |
删除SOE记录, 双机热备时,只删除当前连接的实时库中数据。
| h | rdb_create创建的句柄. |
| datetime_begin | 开始日期时间,ISO格式"2023-1-1T08:0:0.000+08:00" |
| ukey_begin | 开始序号 |
| datetime_end | 结束日期时间(ISO格式), nullptr或者空字符串表示一直删除到结束 |
| ukey_end | 结束序号 |
| pnumdelrecords | 成功后输出删除的记录数 |
| int rdb_soeput | ( | int | h, |
| rec_soe | psoe[], | ||
| int | nsize ) |
写入SOE事件
| h | [in] rdb_create创建的句柄. |
| psoe | [in] SOE事件记录数组 |
| nsize | psoe中的记录个数 |
| int rdb_soequery | ( | int | h, |
| long long | lts, | ||
| unsigned int | autokey, | ||
| long long | lte, | ||
| const char * | sexp, | ||
| rdbcb_OnReadSoes | pfun, | ||
| void * | pParam ) |
查询SOE事件
| h | [in] rdb_create创建的句柄. |
| lts | [in] 开始时标,参见T_TIME |
| autokey | [in] 开始时标处的autokey |
| lte | [in] 结束时标,参见T_TIME,-1表示查询到数据结束 |
| sexp | [in] 查询表达式 |
| pfun | [in] 查询结果记录回调函数 |
| pParam | [in]回调参数 |
| int rdb_soesubscription | ( | int | h, |
| int | flag ) |
订阅SOE事件
| h | [in] rdb_create创建的句柄. |
| flag | [in] 订阅模式; 0:取消订阅; 1:订阅最新; 2:订阅更新的SOE(被处理后的SOE); 3:订阅最新和更新后的SOE. |
| int rdb_soesubscription_ex | ( | int | h, |
| int | flag, | ||
| const char * | station ) |
订阅SOE的高级版,支持通过中心站订阅子站SOE
| h | [in] rdb_create创建的句柄. |
| flag | [in] 订阅模式; 0:取消订阅; 1:订阅最新; 2:订阅更新的SOE(被处理后的SOE); 3:订阅最新和更新后的SOE. |
| station | [in] 子站名,null表示订阅目前连接的站的SOE(和rdb_soesubscription功能同)。 |
| int rdb_soesubscription_setfun | ( | int | h, |
| rdbcb_OnSscPutSoes | fun, | ||
| void * | param ) |
设置处理订阅的SOE事件处理回调函数
| h | [in] rdb_create创建的句柄. |
| fun | [in] 回调函数 |
| param | [in] 回调函数自己带入的参数 |
| int rdb_soeupdate | ( | int | h, |
| rec_soe | psoe[], | ||
| int | nsize ) |
更新SOE事件记录
| h | [in] rdb_create创建的句柄. |
| psoe | [in/out] 事件记录数组,返回时cstatus字段会被改写 |
| nsize | [in] psoe中的记录数 |