LoadRunner訪問Mysql數據庫

這是很久以前編寫的一個測試案例，那時是為了檢查大量往Mysql數據庫里插入數據，看一下數據庫的性能如何？服務器是否會很快就被寫滿了。

前期的准備工作：Mysql 數據庫搭建，LoadRunner，libmysql.dll and 網上搜一份LoadRunner訪問mysq的公共庫。

Step1：Mysql數據庫搭建（這里就不詳細講述如何安裝Mysq數據庫和創建表了）

IP：192.168.1.100

訪問名：root

密碼是：123456

數據庫名是：t3db

訪問端口是：3306

數據庫的相關信息就是這樣了！

Step2：LoadRunner如何連接mysql呢？

以下全都是在網上找到原代碼，非本人創作（忘記作者是誰了，抱歉！）

int rc;
int db_connection;
char *server = "192.168.1.100";   // 數據庫的ip地址
char *user = "root";              // 數據庫訪問用戶名
char *password = "123456";        // 密碼
char *database = "t3db";          // 數據庫名稱
int port = 3306;                  // 訪問端口
int unix_socket = NULL;
int flags = 0;
char** result_row; 
int query_result;
char szSql[256];

int MySqlInit()
{
    rc = lr_load_dll("libmysql.dll");
    db_connection = mysql_init(NULL);

    if (db_connection == NULL) 
    {
        lr_error_message("Insufficient memory");
        lr_abort();
    }

    if(rc!=0)
    {
        lr_error_message("Load MySql.dll Error!");
        lr_abort();
    }

    rc = mysql_real_connect(db_connection,server, user, password, database, port, unix_socket, flags);
    if(rc == NULL)
    {
        lr_error_message("connect mysql error! %s",mysql_error(db_connection));
         mysql_close(db_connection);
         lr_abort();
    }
    return rc;
}

int MySqlUnit()
{
    // 釋放MySQL資源
    mysql_close(db_connection);
    return 0;
}

int InsertValue(char* query)
{
    rc = mysql_query(db_connection,query);
    if (rc != 0) 
    {
        lr_error_message("%s", mysql_error(db_connection));
    }

    query = NULL;
    return rc;
}


int MySqlQuery(char* szSql)
{
    rc = mysql_query(db_connection,szSql);

    if(rc != 0)
    {
        lr_error_message("%s",lr_eval_string("?"));
        lr_error_message("%s", mysql_error(db_connection));
        szSql = NULL;
        return -1;
    }

    query_result = mysql_use_result(db_connection);
    if (query_result == NULL) 
    {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_free_result(query_result);
        szSql = NULL;
        return -2;
    }

    result_row = (char **)mysql_fetch_row(query_result);  
    if (result_row == NULL) 
    {
        lr_error_message("Did not expect the result set to be empty");
        mysql_free_result(query_result);
        szSql = NULL;
        return -3;
    }

    mysql_free_result(query_result);
    szSql = NULL;
    return 0;
}

這里提供了幾個公共函數，看名字大家都明白他們是干啥的。

Step3：Loadrunner里需要怎么編寫寫呢？

1、添加libmysql.dll到你的工程

2、把公共庫添加到你的公共

3、vuser_init

vuser_init()
{
    index = 0;
    MySqlInit();  // 初始化數據庫
    return 0;
}

4、vuser_end

vuser_end()
{
    MySqlUnit();  // 反初始化
    return 0;
}

5、Action

Action()
{
    int resultValue;
    char cIndex[10];
    char onceAccount[1024];    
    char insertQuery[22584];

    index = index +1;

    // 組合插入數據庫的sql語句
    strcpy(insertQuery, "INSERT INTO `t3db`.`role`(GroupID, RoleName, Account, BaseInfo, ExtInfo, LastModify) VALUES('1', '"); 
    strcat(insertQuery, lr_eval_string("{Account}"));
    strcat(insertQuery, itoa(index, cIndex, 10 ));
    strcat(insertQuery, "', 'q1031', '111', '111','2013-02-28 20:42:33')");
    strcat(insertQuery, ";\0");


    lr_start_transaction("Insert");
    resultValue = InsertValue(insertQuery);  // 調用插入函數

    if(resultValue != 0)
    {
        lr_end_transaction("Insert",LR_FAIL);
    }
    else
    {
        lr_end_transaction("Insert",LR_PASS);
    }

    sleep(100);
    return 0;
}

整個過程就是如此了……