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;
|
|||
|
|
}
|