利用loadrunner做mysql压力测试

　　最近跟测试组学习loadrunner的使用，测试组的姑娘们习惯用界面进行操作，而习惯linux平台使用的我很多功能都使用代码来实现了。

　　最近用loadrunner写了一个模拟社区用户压测论坛数据库的一个脚本，进行数据库的压力测试和优化工作。

　　用户行为分析：

　　在社区中，看帖的人是发帖人的10倍以上，而看帖人大概80%以上都在看新帖，20以下的用户有挖坟行为。

　　因此，设定如此的比率：每11个用户，1个发帖，8个看最近30%的帖，两个看老的70%的帖。

　　我的论坛帖子回复表大概是：973505个帖子的回复，两千多万的回帖。

　　根据这些数据，配合mysql的c api，写如下脚本:

　　注：脚本的my_mysql_insert()函数是有问题的，多线程下有一个资源符没处理好，因为还不太了解loadrunner的线程机制，所以留下了一个bug。

　　在做完这个脚本后，我发现我们测试机性能都不错，很难在一个5G大小的单表上主键查询造成很大的压力，所以，计划把dz论坛架设，用php+mysql真实环境下进行压测，这样可以顺便练习http函数下的loadrunner编程。

　　globals.h

　　#ifndef _GLOBALS_H

　　#define _GLOBALS_H

　　#include "lrun.h"

　　#include "web_api.h"

　　#include "lrw_custom_body.h"

　　#include "modal_dialog_callbacks.h"

　　#define random(x) (rand()%x)

　　#include

　　#include

　　vuser_init.c

　　MYSQL *db;

　　MYSQL_ROW record;

　　vuser_init()

　　{

　　char sql[128];

　　MYSQL_RES *results1;

　　lr_load_dll("libmysql.dll");

　　db = mysql_init(NULL);

　　mysql_real_connect(db, "192.168.8.32", "root", "123456", "sunboyu_test", 3311, "/tmp/mysql3311.sock", 1);

　　sprintf(sql, "show tables");

　　mysql_query(db, sql);

　　results1 = mysql_store_result(db);

　　while((record = mysql_fetch_row(results1)))

　　{

　　lr_log_message("table = %s", record[0]);

　　}

　　mysql_free_result(results1);

　　return 0;

　　}

　　vuser_end.c

　　vuser_end()

　　{

　　mysql_close(db);

　　mysql_server_end();

　　return 0;

　　}

　　Action.c

　　Action()

　　{

　　int r1 = 0;

　　char sql[128];

　　r1 = random(11); //10种用户，8种正常访问，两种在挖坟

　　lr_log_message(" %d", r1);

　　if(r1==11)

　　{

　　my_mysql_insert();

　　}

　　else

　　{

　　my_mysql_query( r1 );

　　}

　　return 0;

　　}

　　int my_mysql_query( int randid )

　　{

　　int r2 = 0;

　　int j = 0;

　　int count = 0;

　　int page = 0;

　　char sql[128];

　　MYSQL_RES *results2;

　　if(randid<2) //老数据，小部分 20%

　　{

　　r2 = random(700000);

　　sprintf(sql, "SELECT COUNT(*) AS count FROM posts_jx3 WHERE tid = %d;",r2);

　　lr_log_message("%s",sql);

　　mysql_query(db, sql);

　　results2 = mysql_store_result(db);

　　while((record = mysql_fetch_row(results2)))

　　{

　　lr_log_message("count = %d", record[0]);

　　}

　　mysql_free_result(results2);

　　page = count/10;

　　lr_log_message("page = %d", page);

　　for(j=0;j< =page;j++)

　　{

　　sprintf(sql, "SELECT * FROM posts_jx3 WHERE tid = %d LIMIT %d,10;",r2,j);

　　mysql_query(db, sql);

　　lr_log_message("%s", sql);

　　if (j>0) {

　　results2 = mysql_store_result(db);

　　while((record = mysql_fetch_row(results2)))

　　{

　　lr_log_message("pid = %d", record[0]);

原文转自：http://www.ltesting.net