int  rc; 
int  db_connection; //数据库连接
int  query_result; // 查询结果集 MYSQL_RES
char ** result_row; // 查询的数据行
char *server = "*.*.*.*";   //压测数据库IP地址
char *user = "test";        //压测数据库登录名
char *password = "test";    //压测数据库登录密码
char *database = "TESTDB";  //压测数据库名
int  port = 8066;           //压测数据库端口号
int  unix_socket = NULL; 
int  flags = 1; 

vuser_init()
{

    // 找到libmysql.dll的所在位置.如果安装了mysql，并将dll文件导入了脚本内，可以直接load，不需要路径
    rc = lr_load_dll("libmysql.dll");
    if (rc != 0) 
    {
        lr_error_message("Could not load libmysql.dll");
        lr_abort();
    }

    // 创建MySQL对象
    db_connection = mysql_init(NULL);
    if (db_connection == NULL) 
    {
        lr_error_message("Insufficient memory");
        lr_abort();
    }

    // 连接到MySQL数据库
    rc = mysql_real_connect(db_connection, server, user, password, database, port, unix_socket, flags);
    if (rc == NULL) 
    {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
    }

    //若插入数据中含有中文，则需要设置字符集为GBK，防止中文乱码
     mysql_query(db_connection,lr_eval_string("SET NAMES gbk"));

    return 0;
}

Action()
{
　　//参数化CUS_CODE等参数；
     lr_save_string(lr_eval_string("INSERT INTO `so_customer`  (`ID`, `CREATOR`, `CREATE_TIME`, `UPDATE_TIME`, `VERSION`, `SYNC_VERSION`, `REMARK`, `UDF`, `CUS_NAME`, `CUS_CODE`, `CUS_PHONE`, `CUS_FAX`, `CUS_ADDRESS`, `CUS_OWNER_ID`, `CUS_OWNER_NAME`, `CUS_OPERATION_EMPLOYEE_ID`, `CUS_OPERATION_EMPLOYEE_NAME`, `SETTLE_METHOD`, `CONTACT_PERSON`, `Z_CUS_ID`, `STATUS`, `TIME`) "
                                   "VALUES (NULL, ‘性能测试Creator‘, ‘2017-05-11 19:35:58.000000‘, ‘2017-05-11 19:35:58.000000‘, ‘25‘, ‘99990000000001‘, NULL, NULL, "
                                   "‘{CUS_CODE}‘, ‘{CUS_CODE}‘,NULL, ‘‘, ‘‘, ‘{ID}‘, ‘{NAME}‘, NULL, ‘‘, NULL, ‘性能测试专用‘, "
                                   "‘50000003{cus_id}‘, ‘1‘, ‘2017-05-05 19:13:55‘);"), 
                   "paramInsertQuery");  

    rc = mysql_query(db_connection, lr_eval_string("{paramInsertQuery}")); 
    if (rc!= 0) 
    { 
        lr_error_message("%s", mysql_error(db_connection)); 
        mysql_close(db_connection); 
        lr_abort(); 
    } 
    return 0;
}

vuser_end()
{
    mysql_close(db_connection); 
    return 0;
}