备案控制台
探索云世界
开发者社区 数据库 文章 正文

Loadrunner测试数据库、SQL语句性能

2017-07-10 1815
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL Serverless，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL Serverless，价值2615元额度，1个月
简介：
Action()   
{   
int rc;     
int db_connection; //  数据库 连接   
int query_result; // 查询结果集 MYSQL_RES   
char** result_row; // 查询的数据衕   
     
char *server = "localhost";   
char *user = "root";   
char *password = "123456";   
char *database = " test ";   
int port = 3306;   
int unix_socket = NULL;     
int flags = 0;     
     
// 找到libmysql.dll的所在位置.   
rc = lr_load_dll("C:\\Program Files\\MySQL\\MySQL  Server  5.1\\bin\\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();   
}   
     
// 向数据库插入数据   
// 此处的 {ORDER_ID} 是一个参数，简单 测试 时可以用一个常数代替   
lr_save_string (lr_eval_string("INSERT INTO test_data (order_id) VALUES ({ORDER_ID})"),"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();   
}   
     
// 从数据库读取一个数据并显示   
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1");   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
query_result = mysql_use_result(db_connection);   
if (query_result == NULL) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_free_result(query_result);   
        mysql_close(db_connection);   
        lr_abort();   
}   
// 如果结果集包含多行数据，需要多次调用 mysql_fetch_row 直到返回NULL   
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);   
        mysql_close(db_connection);   
        lr_abort();   
}   
// 保存参数，用于删除这行数据   
lr_save_string(result_row[0], "paramOrderID");   
lr_output_message("Order ID is: %s", lr_eval_string("{paramOrderID}"));   
mysql_free_result(query_result);   
     
// 在事务里更新一行数据，需要用InnoDB引擎   
rc = mysql_query(db_connection, "BEGIN"); //启动事务   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
// 使用 "FOR UPDATE" 锁住要更新的数据行   
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1 FOR UPDATE");     
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
query_result = mysql_use_result(db_connection);   
if (query_result == NULL) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_free_result(query_result);   
        mysql_close(db_connection);   
        lr_abort();   
}   
result_row = (char **)mysql_fetch_row(query_result);     
if (result_row == NULL) {   
        lr_error_message("没有查询到结果");   
        mysql_free_result(query_result);   
        mysql_close(db_connection);   
        lr_abort();   
}   
lr_save_string(result_row[0], "paramOrderID");   
lr_output_message("Order ID is: %s", lr_eval_string("{paramOrderID}"));   
mysql_free_result(query_result);   
lr_save_string(lr_eval_string("UPDATE test_data SET status=TRUE, date_used=NOW() WHERE order_id='{paramOrderID}'"),"paramUpdateQuery");   
rc = mysql_query(db_connection, lr_eval_string("{paramUpdateQuery}"));   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
rc = mysql_query(db_connection, "COMMIT"); // 提交事务   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
     
// 再次查找数据，应该为空了，因为前面的事务更新了标志   
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1");   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
query_result = mysql_use_result(db_connection);   
if (query_result == NULL) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_free_result(query_result);   
        mysql_close(db_connection);   
        lr_abort();   
}   
result_row = (char **)mysql_fetch_row(query_result);   
if (result_row == NULL) {   
        lr_output_message("Result set is empty as expected");   
        mysql_free_result(query_result);   
} else {   
        lr_error_message("Did not expect the result set to contain any rows");   
        mysql_free_result(query_result);   
        mysql_close(db_connection);   
        lr_abort();   
}   
     
// 删除数据   
lr_save_string(lr_eval_string("DELETE FROM test_data WHERE order_id = '{paramOrderID}'"),"paramDeleteQuery");   
rc = mysql_query(db_connection, lr_eval_string("{paramDeleteQuery}"));   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
     
// 释放MySQL资源   
mysql_close(db_connection);   
        return 0;   
}

Action()
{
int rc;
int db_connection; // 数据库连接
int query_result; // 查询结果集 MYSQL_RES
char** result_row; // 查询的数据衕

char *server = "localhost";
char *user = "root";
char *password = "123456";
char *database = "test";
int port = 3306;
int unix_socket = NULL;
int flags = 0;

// 找到libmysql.dll的所在位置.
rc = lr_load_dll("C:\\Program Files\\MySQL\\MySQL Server 5.1\\bin\\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();
}

// 向数据库插入数据
// 此处的 {ORDER_ID} 是一个参数，简单测试时可以用一个常数代替
lr_save_string (lr_eval_string("INSERT INTO test_data (order_id) VALUES ({ORDER_ID})"),"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();
}

// 从数据库读取一个数据并显示
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1");
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}
query_result = mysql_use_result(db_connection);
if (query_result == NULL) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_free_result(query_result);
        mysql_close(db_connection);
        lr_abort();
}
// 如果结果集包含多行数据，需要多次调用 mysql_fetch_row 直到返回NULL
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);
        mysql_close(db_connection);
        lr_abort();
}
// 保存参数，用于删除这行数据
lr_save_string(result_row[0], "paramOrderID");
lr_output_message("Order ID is: %s", lr_eval_string("{paramOrderID}"));
mysql_free_result(query_result);

// 在事务里更新一行数据，需要用InnoDB引擎
rc = mysql_query(db_connection, "BEGIN"); //启动事务
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}
// 使用 "FOR UPDATE" 锁住要更新的数据行
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1 FOR UPDATE");
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}
query_result = mysql_use_result(db_connection);
if (query_result == NULL) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_free_result(query_result);
        mysql_close(db_connection);
        lr_abort();
}
result_row = (char **)mysql_fetch_row(query_result);
if (result_row == NULL) {
        lr_error_message("没有查询到结果");
        mysql_free_result(query_result);
        mysql_close(db_connection);
        lr_abort();
}
lr_save_string(result_row[0], "paramOrderID");
lr_output_message("Order ID is: %s", lr_eval_string("{paramOrderID}"));
mysql_free_result(query_result);
lr_save_string(lr_eval_string("UPDATE test_data SET status=TRUE, date_used=NOW() WHERE order_id='{paramOrderID}'"),"paramUpdateQuery");
rc = mysql_query(db_connection, lr_eval_string("{paramUpdateQuery}"));
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}
rc = mysql_query(db_connection, "COMMIT"); // 提交事务
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}

// 再次查找数据，应该为空了，因为前面的事务更新了标志
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1");
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}
query_result = mysql_use_result(db_connection);
if (query_result == NULL) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_free_result(query_result);
        mysql_close(db_connection);
        lr_abort();
}
result_row = (char **)mysql_fetch_row(query_result);
if (result_row == NULL) {
        lr_output_message("Result set is empty as expected");
        mysql_free_result(query_result);
} else {
        lr_error_message("Did not expect the result set to contain any rows");
        mysql_free_result(query_result);
        mysql_close(db_connection);
        lr_abort();
}

// 删除数据
lr_save_string(lr_eval_string("DELETE FROM test_data WHERE order_id = '{paramOrderID}'"),"paramDeleteQuery");
rc = mysql_query(db_connection, lr_eval_string("{paramDeleteQuery}"));
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}

// 释放MySQL资源
mysql_close(db_connection);
return 0;
}  








====================================分割线================================



最新内容请见作者的GitHub页：http://qaseven.github.io/

文章标签：
云数据库 RDS MySQL 版
关系型数据库
数据库
测试技术
SQL
MySQL
关键词：
数据库sql
SQL数据库
数据库性能
数据库测试
测试数据库
相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境，其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
玄学酱
目录
相关文章
Geek极安云科
|
2天前
|
SQL 数据库
SQL数据库基础语法-查询语句
SQL数据库基础语法-查询语句
Geek极安云科
21 7
Geek极安云科
|
2天前
|
SQL 存储 数据库
SQL数据库基础语法-增删改
SQL数据库基础语法-增删改
Geek极安云科
18 5
SQL数据库基础语法-增删改
vohelon
|
2天前
|
SQL 关系型数据库 分布式数据库
提升数据库性能
【5月更文挑战第6天】提升数据库性能
vohelon
15 1
足球一吧
|
4天前
|
SQL 数据库 Windows
sql数据库安装过程,SQL数据库的安装过
本文概述了安装SQL Server数据库的步骤：准备硬件和软件环境，运行安装程序，选择安装类型，接受许可协议，设定安装路径和组件，配置实例和服务账户，选择身份验证模式，配置其他设置，然后安装并完成。安装后需检查验证SQL Server是否正常工作。确保遵循步骤以顺利完成安装。
足球一吧
42 3
1941623231718325
|
8天前
|
存储 大数据 测试技术
矢量数据库的性能测试与评估方法
【4月更文挑战第30天】本文探讨了矢量数据库的性能测试与评估方法，强调其在大数据和AI时代的重要性。文中介绍了负载测试、压力测试、容量测试、功能测试和稳定性测试五大评估方法，以及实施步骤，包括确定测试目标、设计用例、准备环境、执行测试和分析结果。这些方法有助于确保数据库的稳定性和高效性，推动技术发展。
1941623231718325
7 0
1941623231718325
|
8天前
|
存储 缓存 固态存储
优化矢量数据库性能：技巧与最佳实践
【4月更文挑战第30天】本文探讨了优化矢量数据库性能的技巧和最佳实践，包括硬件（如使用SSD、增加内存和利用多核处理器）、软件（索引优化、查询优化、数据分区和压缩）和架构（读写分离、分布式架构及缓存策略）方面的优化措施。通过这些方法，可以提升系统运行效率，应对大数据量和复杂查询的挑战。
1941623231718325
15 0
听风de歌
|
8天前
|
分布式计算 Hadoop 测试技术
Hadoop节点网络性能的带宽测试选择测试工具
【4月更文挑战第23天】
听风de歌
19 2
听风de歌
|
8天前
|
分布式计算 Hadoop 测试技术
Hadoop节点网络性能的带宽测试设置测试环境
【4月更文挑战第23天】
听风de歌
20 1
Hadoop节点网络性能的带宽测试设置测试环境
听风de歌
|
8天前
|
分布式计算 Hadoop 测试技术
Hadoop节点网络性能的带宽测试
【4月更文挑战第23天】
听风de歌
23 1
香甜可口草莓蛋糕
|
8天前
|
SQL 关系型数据库 MySQL
利用 SQL 注入识别数据库方法总结
利用 SQL 注入识别数据库方法总结
香甜可口草莓蛋糕
15 4

热门文章

最新文章

  • 1
    MongoDB性能最佳实践：如何制定更有效的基准测试？
  • 2
    深入理解自动化测试框架Selenium的设计与实现
  • 3
    如何入门做物联网系统压测？
  • 4
    使用金庸的著作，来测试阿里通义千问最新开放的长文档处理功能
  • 5
    提升软件测试效率与质量的策略
  • 6
    渗透测试工程师面试题大全
  • 7
    《手把手教你》系列技巧篇（十八）-java+ selenium自动化测试-元素定位大法之By css中卷（详细教程）
  • 8
    《手把手教你》系列技巧篇（十四）-java+ selenium自动化测试-元素定位大法之By xpath上卷（详细教程）
  • 9
    如何进行有效的Apollo测试：单元测试和集成测试指南
  • 10
    软件测试|docker搭建Jenkins+Python+allure自动化测试环境
  • 1
    JAVA数据库的基础知识
    17
  • 2
    启动多个jar包来监听同一个数据库的binlog
    23
  • 3
    OceanBase数据库的主备库参照的配置文件
    38
  • 4
    参与TiDB社区，共筑开源数据库的未来
    34
  • 5
    TiDB与MySQL、PostgreSQL等数据库的比较分析
    155
  • 6
    sql数据库查询语句大全
    23
  • 7
    面对多种国产数据库，如何选择合适的技术栈和发展方向
    37
  • 8
    宝塔数据库崩溃解决方案详解
    54
  • 9
    视觉智能平台常见问题之创建人脸数据库失败如何解决
    27
  • 10
    TiDB的优势：为何选择TiDB作为您的数据库解决方案
    116

    • 相关课程

    更多
  • SQL入门与实践
  • 数据库核心概念
  • 从传统数据库到云数据库演进
  • 数据库常见问题排查
  • 数据库及SQL/MySQL基础
  • SQL进阶及查询

    • 相关电子书

    更多
  • SQL Server 2017
  • GeoMesa on Spark SQL
  • 原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili

    • 相关实验场景

    更多
  • 测试场景（RDS无优惠）
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 玩转MaxCompute SQL! 30分钟搞定数据分析挖掘
  • 快速体验PolarDB开源数据库
  • 使用SQL语句实现数据查询操作
  • 使用SQL语句管理索引
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）