94 lines
2.6 KiB
C
94 lines
2.6 KiB
C
#include "tmain.h"
|
||
|
||
#define QUEUE_USER_INFO 21
|
||
|
||
typedef struct __QUEUE_USER_INFO
|
||
{
|
||
long acct_id;
|
||
char user_no[21];
|
||
char user_type[2];
|
||
char user_nm[81];
|
||
char user_addr[161];
|
||
char user_phone[31];
|
||
}dbUser;
|
||
|
||
typedef unsigned long long uint64;
|
||
extern uint64 get_tick_time();
|
||
|
||
typedef struct _ST_ARG_
|
||
{
|
||
int threadIndex;
|
||
uint64 rows;
|
||
uint64 start;
|
||
}ARG;
|
||
|
||
void* vPushUserInfo(void *arg)
|
||
{
|
||
int i = 0;
|
||
dbUser stUser;
|
||
ARG *pArgInfo = (ARG *)arg;
|
||
SATvm *pstSavm = (SATvm *)pCloneSATvm();
|
||
|
||
queueinit(pstSavm, stUser, QUEUE_USER_INFO); // 绑定变量
|
||
for(i = 0; i < pArgInfo->rows; i++)
|
||
{
|
||
stUser.acct_id = pArgInfo->start + i; // 对结构体赋值
|
||
strcpy(stUser.user_no, "20180223"); // 对结构体赋值
|
||
strcpy(stUser.user_type, "1"); // 对结构体赋值
|
||
strcpy(stUser.user_nm, "Savens Liu"); // 对结构体赋值
|
||
strcpy(stUser.user_addr, "China"); // 对结构体赋值
|
||
strcpy(stUser.user_phone, "18672911111"); // 对结构体赋值
|
||
|
||
if(RC_SUCC != lPush(pstSavm)) // 插入记录
|
||
{
|
||
fprintf(stderr, "Insert error:(%d)(%s)\n", pstSavm->m_lErrno,
|
||
sGetTError(pstSavm->m_lErrno));
|
||
return NULL;
|
||
}
|
||
}
|
||
|
||
vCloneFree(pstSavm);
|
||
return NULL;
|
||
}
|
||
|
||
int main(int argc, char *argv[])
|
||
{
|
||
uint64 uTime = 0;
|
||
ARG arg[100];
|
||
pthread_t thread[10];
|
||
int i = 0, j = 0, rows = 0, num;
|
||
SATvm *pstSavm = (SATvm *)pGetSATvm();
|
||
|
||
if(1 != argc)
|
||
num = strlen(argv[1])>0?atoi(argv[1]):1;
|
||
else
|
||
num = 1;
|
||
|
||
/* 初始化QUEUE_USER_INFO表，每张表都需要初始化一次, 对于表重建后，需要重新初始化一次。*/
|
||
vHoldConnect(pstSavm);
|
||
if(RC_SUCC != lAttchTable(pstSavm, QUEUE_USER_INFO))
|
||
{
|
||
fprintf(stderr, "attch failed, err:(%d)(%s)\n", pstSavm->m_lErrno, sGetTError(pstSavm->m_lErrno));
|
||
return RC_FAIL;
|
||
}
|
||
|
||
rows = 4000000 / num;
|
||
for(uTime = get_tick_time(); i < num; i++)
|
||
{
|
||
arg[i].threadIndex = i + 1;
|
||
arg[i].start = rows * i;
|
||
arg[i].rows = rows;
|
||
pthread_create(&thread[i], NULL, vPushUserInfo, (void*)&arg[i]);
|
||
}
|
||
|
||
for(j = 0; j < num; j++)
|
||
pthread_join(thread[j], NULL);
|
||
|
||
fprintf(stdout, "cost_time:[%lld]\r\n", get_tick_time() - uTime);
|
||
vTvmDisconnect(pstSavm);
|
||
|
||
fprintf(stdout, "新增记录成功, completed successfully!!!\n");
|
||
fflush(stderr);
|
||
return RC_SUCC;
|
||
}
|