分別庫檔案和程式碼新增到Loadrunner bin目錄和include目錄下

2、vuser_init檔案新增程式碼：

#include "Ptt_Mysql.h"
#include "mysql.h"
#include "mysql_com.h"
#include "mysql_time.h"
#include "mysql_version.h"
#include "typelib.h"
#include "my_list.h"
#include "my_alloc.h"
#define MYSQLSERVER "172.16.1.220"
#define MYSQLUSERNAME "dbuser"
#define MYSQLPASSWORD "
 
[email protected]"
#define MYSQLDB "sroa_lyt"
#define MYSQLPORT "3309"
char chQuery[1024];
int statu=1;
int status=0;
MYSQL *Mconn;
char sql_query[256], sql_sub_query[50];
int i=0, res=0, conn_fail=0, conn_iter=0;
char response[50];// to go 
vuser_init()
{
	lr_load_dll ("libmysql.dll");
	lr_start_transaction("mysql_conn"); //設定一個連線資料庫的事務
        /*------------------------------------------------------------------------*/
	/* Initialise MySQL */
	if(!(Mconn = mysql_init(NULL)))
	{
		lr_message("Error -1: Cannot initialize MySQL - %s", mysql_error(Mconn));
		//return -1;
		statu = 0;
		lr_end_transaction("mysql_conn", LR_FAIL); //初始化資料庫失敗判定事務失敗
	}
        /*------------------------------------------------------------------------*/
	do
	{
		/* Connect to database */
		if (!mysql_real_connect(Mconn, MYSQLSERVER, MYSQLUSERNAME, MYSQLPASSWORD, MYSQLDB, atoi(MYSQLPORT), NULL, 0))
		{
			conn_fail = -2;
			conn_iter++;
			sleep(100);
		}
		else
			conn_fail = 0;
	}
	while(conn_fail < 0 && conn_iter < 10);
	if (conn_fail < 0)
	{
		lr_message("Error -2: %s", mysql_error(Mconn));
		//mysql_close(Mconn);
		//return -2;
		statu = 0;
		lr_end_transaction("mysql_conn", LR_FAIL); //連線資料庫失敗判定事務失敗
	}
	else
	{
		//lr_message("MySql - Good Connection");
		//mysql_close(Mconn);
		statu = 1;
		lr_end_transaction("mysql_conn", LR_PASS); //連線資料庫成功，事務通過。
	}
	return 0;
}
 

3、Action檔案新增程式碼

Action()
{
	if(statu){ //成功連線資料庫後才進行執行sql的操作
		lr_start_transaction("mysql_select");
		sprintf(chQuery, "SELECT id, lb, title, nr, attachment_id, attachment_name, pic_name, fbsj, fbbm, fbr, vcount FROM sroa_lyt.oa_news;");//查詢論壇使用者
		//sprintf(chQuery,"UPDATE lr_test SET password = "%s" WHERE username='tom'",lr_eval_string ("{pwd}"));
		/*
		sprintf(chQuery,"update pre_ucenter_members set username='dd' where username='qq' ");//更改使用者名稱qq為dd
		sprintf(chQuery,"delete from pre_ucenter_members ORDER BY uid desc LIMIT 1");//刪除最後新增的一條資料
		*/
		status = lr_mysql_query(Mconn, chQuery);
		if(status!=0){ //判斷sql是否執行成功
			lr_end_transaction("mysql_select",LR_FAIL);
		}else{
			lr_end_transaction("mysql_select",LR_PASS);
		}

		lr_start_transaction("mysql_insert");
		sprintf(chQuery,"insert into oa_news(id, lb, title, nr, attachment_id, attachment_name, pic_name, fbsj, fbbm, fbr, vcount) values(9,9,'
 
[email protected]','test','','','teste','',6,'test',0)");//插入資料
		status = lr_mysql_query(Mconn, chQuery);
		if(status!=0){ //判斷sql是否執行成功
			lr_end_transaction("mysql_insert",LR_FAIL);
		}else{
			lr_end_transaction("mysql_insert",LR_PASS);
		}
	} 
	return 0;
}

4、vuser_end檔案新增程式碼：

vuser_end()
{
	lr_mysql_disconnect(Mconn); //關閉資料庫連線
	return 0;
}