AI 助理
备案控制台登录注册
开发者社区 数据库 文章 正文

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

2017-07-10 1873
版权
举报
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
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数据库
数据库性能
SQL性能
测试数据库
相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL，然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
玄学酱
+关注
20593文章432问答
目录
打赏
0
0
0
0
26198
分享
相关文章
蓝易云
|
8天前
|
SQL 数据库连接 Linux
数据库编程：在PHP环境下使用SQL Server的方法。
看看你吧，就像一个调皮的小丑鱼在一片广阔的数据库海洋中游弋，一路上吞下大小数据如同海中的珍珠。不管有多少难关，只要记住这个流程，剩下的就只是探索未知的乐趣，沉浸在这个充满挑战的数据库海洋中。
蓝易云
32 16
游客mass6jalwg5qm
|
10天前
|
SQL 关系型数据库 MySQL
如何优化SQL查询以提高数据库性能？
这篇文章以生动的比喻介绍了优化SQL查询的重要性及方法。它首先将未优化的SQL查询比作在自助餐厅贪多嚼不烂的行为，强调了只获取必要数据的必要性。接着，文章详细讲解了四种优化策略：**精简选择**（避免使用`SELECT *`）、**专业筛选**（利用`WHERE`缩小范围）、**高效联接**（索引和限制数据量）以及**使用索引**（加速搜索）。此外，还探讨了如何避免N+1查询问题、使用分页限制结果、理解执行计划以及定期维护数据库健康。通过这些技巧，可以显著提升数据库性能，让查询更高效流畅。
游客mass6jalwg5qm
61 18
TDengine
|
15天前
|
物联网 测试技术 API
时序数据库 InfluxDB 3.0 版本性能实测报告：写入吞吐量提升效果验证
TSBS 测试表明，对于少于 100 万台设备的数据集，InfluxDB OSS 3.0 的数据写入速度实际上比 InfluxDB OSS 1.8 更慢。 对于 100 万台及以上设备的数据集，InfluxDB OSS 3.0 的数据写入性能才开始超过 InfluxDB OSS 1.8。 InfluxDB OSS 3.0 的数据写入接口与 InfluxDB 1.8 并不兼容，用户无法顺利迁移。
TDengine
54 7
阿里云瑶池数据库_
|
2月前
|
Cloud Native 关系型数据库 分布式数据库
世界第一！阿里云PolarDB刷新全球数据库性能及性价比记录
世界第一！阿里云PolarDB刷新全球数据库性能及性价比记录
阿里云瑶池数据库_
141 22
1639437117631681
|
2月前
|
数据库
【YashanDB 知识库】误配置 SYSTEM 级别的 STATISTICS_LEVEL 参数为 ALL 导致数据库性能下降
**标题：误配置 SYSTEM 级别的 STATISTICS_LEVEL 参数为 ALL 导致数据库性能下降** **简介：** 数据库性能骤降至正常水平的百分之一，主要表现为大量 free buffer wait 等待事件。原因是系统级别 STATISTICS_LEVEL 被误设为 ALL。解决方法是将其恢复为默认值 TYPICAL，执行命令：`ALTER SYSTEM SET statistics_level='TYPICAL' SCOPE=BOTH;` 以恢复正常性能。
1639437117631681
36 4
TDengine
|
15天前
|
存储 NoSQL MongoDB
从 MongoDB 到 时序数据库 TDengine，沃太能源实现 18 倍写入性能提升
沃太能源是国内领先储能设备生产厂商，数十万储能终端遍布世界各地。此前使用 MongoDB 存储时序数据，但随着设备测点增加，MongoDB 在存储效率、写入性能、查询性能等方面暴露出短板。经过对比，沃太能源选择了专业时序数据库 TDengine，生产效能显著提升：整体上，数据压缩率超 10 倍、写入性能提升 18 倍，查询在特定场景上也实现了数倍的提升。同时减少了技术架构复杂度，实现了零代码数据接入。本文将对 TDengine 在沃太能源的应用情况进行详解。
TDengine
31 0
数据库社区运营小北
|
2月前
|
Cloud Native 关系型数据库 分布式数据库
刷新世界纪录！阿里云登顶全球数据库性能及性价比排行榜
阿里云PolarDB云原生数据库在TPC-C测试中登顶全球性能及性价比排行榜。此次突破展示了PolarDB在单核性能、横向扩展及软硬件结合上的创新，标志着中国基础软件的重大成就。
数据库社区运营小北
108 1
wiker24
|
2月前
|
SQL 存储 关系型数据库
【SQL技术】不同数据库引擎 SQL 优化方案剖析
不同数据库系统（MySQL、PostgreSQL、Doris、Hive）的SQL优化策略。存储引擎特点、SQL执行流程及常见操作（如条件查询、排序、聚合函数）的优化方法。针对各数据库，索引使用、分区裁剪、谓词下推等技术，并提供了具体的SQL示例。通用的SQL调优技巧，如避免使用`COUNT(DISTINCT)`、减少小文件问题、慎重使用`SELECT *`等。通过合理选择和应用这些优化策略，可以显著提升数据库查询性能和系统稳定性。
wiker24
99 9
码农小达人
|
2月前
|
Cloud Native 关系型数据库 分布式数据库
世界第一！阿里云PolarDB刷新全球数据库性能及性价比记录
世界第一！阿里云PolarDB刷新全球数据库性能及性价比记录
码农小达人
47 0
数据库社区运营小北
|
2月前
|
Cloud Native 关系型数据库 分布式数据库
世界第一！阿里云PolarDB登顶全球数据库性能及性价比排行榜！
2月26日，阿里云PolarDB在2025开发者大会上登顶全球数据库性能及性价比排行榜。此次突破标志着中国基础软件取得里程碑成就，PolarDB凭借创新的云原生架构，成功应对全球最大规模并发交易峰值，在性能、可扩展性等方面领先全球。
数据库社区运营小北
158 0

热门文章

最新文章

  • 1
    Windows用户必备：Postman v11详细安装指南与API测试入门教程（附官网下载
    23
  • 2
    如何测试中间件优化后的 Pinia 状态管理？
    1
  • 3
    Python 高级编程与实战：构建自动化测试框架
    6
  • 4
    MBTI十六型人格职业性格测试源码完整版
    19
  • 5
    【硬件测试】基于FPGA的4ASK调制解调通信系统开发与硬件片内测试,包含信道模块,误码统计模块,可设置SNR
    4
  • 6
    解读 | 金融长上下文基准测试FailSafeQA：解锁金融领域LLM真实的审慎性和容错性
    6
  • 7
    Python测试淘宝店铺所有商品接口的详细指南
    5
  • 8
    【硬件测试】基于FPGA的MSK调制解调系统系统开发与硬件片内测试,包含信道模块,误码统计模块,可设置SNR
    3
  • 9
    【硬件测试】基于FPGA的16QAM调制+软解调系统开发与硬件片内测试,包含信道模块,误码统计模块,可设置SNR
    3
  • 10
    Apifox工具让我的 Socket.IO 测试效率翻倍
    7
  • 1
    解决大小写、保留字与特殊字符问题！Oracle双引号在SQL中的特殊应用
    23
  • 2
    OmniSQL：开源文本到SQL神器！自然语言秒转查询到复杂多表连接等SQL需求
    91
  • 3
    YashanDB SQL语言
    13
  • 4
    SQL查询优化：where子句的高效使用方式
    37
  • 5
    SQL查询优化：where子句的高效使用方式。
    32
  • 6
    【YashanDB知识库】共享利用Python脚本解决Oracle的SQL脚本@@用法
    18
  • 7
    YashanDB SQL 引擎
    20
  • 8
    【YashanDB知识库】如何从内存中获取SQL语句的执行计划
    11
  • 9
    数据库编程：在PHP环境下使用SQL Server的方法。
    32
  • 10
    【YashanDB知识库】共享利用Python脚本解决Oracle的SQL脚本@@用法
    13

    • 相关课程

    更多
  • 数据库的前世今生
  • 数据库核心概念
  • 从传统数据库到云数据库演进
  • 数据库常见问题排查
  • 数据库及SQL/MySQL基础
  • 高校精品课-西安交通大学 -数据库理论与技术

    • 相关电子书

    更多
  • 阿里云&信通院《Serverless数据库技术研究报告》
  • DTCC 2022大会集锦《云原生一站式数据库技术与实践》
  • 阿里云瑶池数据库精要2022版

    • 相关实验场景

    更多
  • 使用DAS实现数据库SQL优化
  • 自建数据库迁移到云数据库
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 云原生HTAP数据库，让你的交易和分析一库搞定
  • 快速体验PolarDB开源数据库
  • SQLServer数据库的创建
    • 下一篇
    阿里云oss简介和如何对接使用
    AI助理

    你好，我是AI助理

    可以解答问题、推荐解决方案等