25 #include "bson/bson.h"
33 #define SDB_PAGESIZE_4K 4096
35 #define SDB_PAGESIZE_8K 8192
37 #define SDB_PAGESIZE_16K 16384
39 #define SDB_PAGESIZE_32K 32768
41 #define SDB_PAGESIZE_64K 65536
43 #define SDB_PAGESIZE_DEFAULT 0
69 #define SDB_INVALID_HANDLE ((ossValuePtr) 0)
95 const CHAR *pDescription,
96 const CHAR *pDetail ) ;
108 #define sdbCreateReplicaNode sdbCreateNode
110 #define sdbRemoveReplicaNode sdbRemoveNode
112 #define sdbGetReplicaNodeMaster sdbGetNodeMaster
114 #define sdbGetReplicaNodeSlave sdbGetNodeSlave
116 #define sdbGetReplicaNodeByName sdbGetNodeByName
118 #define sdbGetReplicaNodeByHost sdbGetNodeByHost
120 #define sdbGetReplicaNodeSddr sdbGetNodeAddr
122 #define sdbStartReplicaNode sdbStartNode
124 #define sdbStopReplicaNode sdbStopNode
126 #define sdbReleaseReplicaNode sdbReleaseNode
129 #define QUERY_FORCE_HINT 0x00000080
131 #define QUERY_PARALLED 0x00000100
133 #define QUERY_WITH_RETURNDATA 0x00000200
135 #define QUERY_PREPARE_MORE 0x00004000
137 #define QUERY_KEEP_SHARDINGKEY_IN_UPDATE 0x00008000
142 #define QUERY_FOR_UPDATE 0x00010000
147 #define QUERY_FOR_SHARE 0x00040000
151 #define FLG_INSERT_CONTONDUP 0x00000001
155 #define FLG_INSERT_REPLACEONDUP 0x00000004
161 #define FLG_INSERT_CONTONDUP_ID 0x00000020
164 #define FLG_INSERT_REPLACEONDUP_ID 0x00000040
166 #define FLG_INSERT_RETURN_OID 0x10000000
169 #define UPDATE_KEEP_SHARDINGKEY QUERY_KEEP_SHARDINGKEY_IN_UPDATE
176 #if defined( SDB_ENGINE ) || defined( SDB_TOOL ) || defined ( SDB_FMP ) || defined ( SDB_SHELL )
182 const MsgHeader *sendMsg,
183 MsgHeader **recvMsg, INT32 *size,
185 BOOLEAN endianConvert ) ;
214 const CHAR *pCipherFile,
215 CHAR *pUser, CHAR *pPasswd ) ;
231 SDB_EXPORT INT32
sdbConnect (
const CHAR *pHostName,
const CHAR *pServiceName,
232 const CHAR *pUsrName,
const CHAR *pPasswd ,
247 SDB_EXPORT INT32
sdbConnect1 (
const CHAR **pConnAddrs, INT32 arrSize,
248 const CHAR *pUsrName,
const CHAR *pPasswd ,
265 SDB_EXPORT INT32
sdbSecureConnect (
const CHAR *pHostName,
const CHAR *pServiceName,
266 const CHAR *pUsrName,
const CHAR *pPasswd ,
282 const CHAR *pUsrName,
const CHAR *pPasswd ,
301 const CHAR *pPasswd ) ;
313 const CHAR *pPasswd ) ;
569 UINT32 traceBufferSize,
591 const CHAR *pDumpFileName ) ;
710 const CHAR *pCollectionFullName,
724 const CHAR *pCollectionSpaceName,
777 CHAR *pBuffer, INT32 size ) ;
809 const CHAR *pCollectionSpaceName,
831 const CHAR *pCollectionSpaceName,
844 const CHAR *pCollectionSpaceName ) ;
860 const CHAR *pCollectionSpaceName,
886 const CHAR *pRGName ) ;
934 const INT32 *positionsArray,
935 INT32 positionsCount,
951 const CHAR *pNodeName,
968 const CHAR *pHostName,
969 const CHAR *pServiceName,
987 const CHAR **ppHostName,
988 const CHAR **ppServiceName,
989 const CHAR **ppNodeName,
1031 const CHAR *pHostName,
1032 const CHAR *pServiceName,
1033 const CHAR *pDatabasePath,
1051 const CHAR *pHostName,
1052 const CHAR *pServiceName,
1053 const CHAR *pDatabasePath,
1069 const CHAR *pHostName,
1070 const CHAR *pServiceName,
1152 const CHAR *code ) ;
1163 const CHAR *spName ) ;
1213 const CHAR *pCollectionName,
1230 const CHAR *pCollectionName,
1275 const CHAR *pCollectionName,
1321 const CHAR *pCollectionName ) ;
1333 CHAR *pBuffer, INT32 size ) ;
1348 const CHAR *pOldName,
1349 const CHAR *pNewName,
1392 CHAR *pResult, INT32 size ) ;
1454 CHAR *pBuffer, INT32 size ) ;
1466 CHAR *pBuffer, INT32 size ) ;
1487 const CHAR *pSourceRG,
1488 const CHAR *pTargetRG,
1489 const bson *pSplitCondition,
1490 const bson *pSplitEndCondition ) ;
1513 const CHAR *pSourceRG,
1514 const CHAR *pTargetRG,
1515 const bson *pSplitCondition,
1516 const bson *pSplitEndCondition,
1532 const CHAR *pSourceRG,
1533 const CHAR *pTargetRG,
1551 const CHAR *pSourceRG,
1552 const CHAR *pTargetRG,
1573 const CHAR *pIndexName,
1575 BOOLEAN isEnforced ) ;
1597 const CHAR *pIndexName,
1600 INT32 sortBufferSize ) ;
1624 const CHAR *pIndexName,
1639 const CHAR *pIndexName,
1653 const CHAR *pIndexName,
1678 const CHAR *pIndexName ) ;
1745 bson *obj, bson_iterator *pId ) ;
1795 bson *obj, INT32 flags, bson *pResult ) ;
1854 SINT32 flags, bson **objs, SINT32 num ) ;
1906 SINT32 flags, bson **objs,
2042 bson *setOnInsert ) ;
2553 SDB_EXPORT
void sdbReleaseDC (
sdbDCHandle cHandle ) ;
2599 bson **obj, SINT32 num,
2614 const CHAR *subClFullName,
2626 const CHAR *subClFullName) ;
2760 const SINT64 *taskIDs,
2855 const CHAR *pDomainName,
2868 const CHAR *pDomainName ) ;
2881 const CHAR *pDomainName,
2928 const bson *options ) ;
2943 const bson * options ) ;
2959 const bson * options ) ;
2976 const bson * options ) ;
2998 const bson * options ) ;
3093 const CHAR *pTimeStamp,
3121 const bson_oid_t *oid,
3201 const bson_oid_t *oid ) ;
3213 const bson_oid_t *oid, INT64 length ) ;
3374 const bson *options ) ;
3384 const bson *options ) ;
3395 const CHAR *fullName ) ;
3417 const CHAR *hostName,
3418 const CHAR *serviceName,
3419 const bson *options ) ;
3439 const CHAR *hostName,
3440 const CHAR *serviceName,
3441 const bson *options ) ;
3454 const bson *args ) ;
3478 const bson * args ) ;
3498 const bson * args ) ;
3526 const bson * options ) ;
3538 const bson * options ) ;
3561 const bson *options ) ;
3596 const CHAR *pIndexName,
3612 const CHAR *pIndexName,
3636 SDB_EXPORT INT32 sdbGetDCName(
sdbDCHandle cHandle, CHAR *pBuffer, INT32 size ) ;
3654 SDB_EXPORT INT32 sdbGetDCDetail(
sdbDCHandle cHandle, bson *retInfo ) ;
3662 SDB_EXPORT INT32 sdbActivateDC(
sdbDCHandle cHandle ) ;
3670 SDB_EXPORT INT32 sdbDeactivateDC(
sdbDCHandle cHandle ) ;
3679 SDB_EXPORT INT32 sdbEnableReadOnly(
sdbDCHandle cHandle, BOOLEAN isReadOnly ) ;
3800 bson *configs, bson *options ) ;
3818 bson *configs, bson *options ) ;
3833 const CHAR *pOldName,
3834 const CHAR *pNewName,
3922 const CHAR *pSequenceName,
3923 const bson *options,
3937 const CHAR *pSequenceName,
3951 const CHAR *pOldName,
3952 const CHAR *pNewName ) ;
3963 const CHAR *pSequenceName ) ;
3990 const bson *options ) ;
4020 const INT64 value ) ;
4037 const INT32 fetchNum,
4040 INT32 *increment ) ;
4050 const INT64 startValue ) ;