loadrunner 测试Mysql执行insert操作

//在数据库下新建表

CREATE TABLE tt (
id INT NOT NULL PRIMARY KEY AUTO_INCREMENT, //主表索引，自增
`name` VARCHAR(20)
)

//存储方式

alter table <表名> engine = innodb;

--------------------------------------------------------------------------

int db_connection;

vuser_init()
{
　　char** result_row;
　　char *server = "xxx.xx.x.xx"; // 数据库的ip地址
　　char *user = "ceshi001"; // 数据库访问用户名
　　char *password = "12345678"; // 密码
　　char *database = "ceshi"; // 数据库名称
　　int port = 3306; // 访问端口

　　int unix_socket = NULL;
　　int flags = 0; 

　　int rc;
　　int index = 0;

　　rc = lr_load_dll("D:\\libmysql.dll"); //解压包中有，请自行设置目录

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

　　db_connection = mysql_init(NULL);

　　if (db_connection == NULL)
　　{
　　　　lr_error_message("Insufficient memory");
　　　　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 0;
}

Action()
{
　　int rc;
　　char** InsertSql[222];
　　strcpy(InsertSql,"INSERT INTO tt(name) VALUES (‘xxx‘)");
　　lr_start_transaction("Insert");
　　rc = mysql_query(db_connection,InsertSql);
　　lr_end_transaction("Insert", LR_AUTO);
　　return 0;
}

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

loadrunner 测试Mysql执行insert操作

标签：