# MySQL 数据库
# 简介
炸毛框架的数据库组件对接了 MySQL 连接池,在使用过程中无需配置即可实现 MySQL 查询,同时拥有高并发。
目前 2.5 版本后炸毛框架底层采用了 doctrine/dbal
组件,可以方便地构建 SQL 语句。
本章大体查询内容均以下表 users
为基础:
id | username | gender | update_time |
---|---|---|---|
1 | jack | man | 2021-10-12 |
2 | rose | woman | 2021-10-11 |
# 配置
炸毛框架的数据库组件支持原生 SQL、查询构造器,去掉了复杂的对象模型关联,同时默认为数据库连接池,使开发变得简单。
数据库的配置位于 config/global.php
文件的 mysql_config
段,见 全局配置。
如果 mysql_config.host
字段为空,则不创建数据库连接池,填写后将创建,且默认保持长连接。
# 执行 SQL 语句
在一开始,无论你做什么数据库操作,均需要获取一个 \ZM\MySQL\MySQLWrapper
作为你的操作对象。
/** @var \ZM\MySQL\MySQLWrapper $wrapper */
$wrapper = \ZM\MySQL\MySQLManager::getWrapper();
2
提示
这部分内容部分直接取自 DBAL - Data Retrieval And Manipulation (opens new window) 原文并直接翻译,如有实际不同请提交 Issue 反馈。
# 执行预处理 SQL 语句
预处理查询很巧妙地解决了 SQL 注入问题,并且可以方便地绑定参数进行查询。
预处理一般是指使用 ?
占位符或 :xxx
命名标签进行参数留空,先处理 SQL 语句再填入数据。
一般 ?
具有前后位置性,例如如下的查询:
$sql = "SELECT * FROM users WHERE id = ? AND username = ?";
$stmt = $wrapper->getConnection()->prepare($sql);
$stmt->bindValue(1, "1");
$stmt->bindValue(2, "jack");
$resultSet = $stmt->executeQuery();
2
3
4
5
其中 $resultSet
与 Statement
方法相似,此处的对象可能是 数据库语句对象 或 数据库结果对象(结果对象与语句对象的 fetchXXX()
部分一致)。
这里也可以使用命名标签,使用标签可以给相同参数处使用同一个标签:
$sql = "SELECT * FROM users WHERE gender = :name OR username = :name";
$stmt = $wrapper->getConnection()->prepare($sql);
$stmt->bindValue("name", "jack");
$resultSet = $stmt->executeQuery();
2
3
4
# 执行常规语句
执行常规语句为 statement
方式执行,此方法执行后只返回影响的行数,而不返回结果,适用于 UPDATE
等语句。
<?php
$count = $wrapper->executeStatement('UPDATE users SET username = ? WHERE id = ?', array('jwage', 1));
echo $count; // 1
2
3
# 执行查询语句
为给定的 SQL 创建一个准备好的语句并将参数传递给 executeQuery 方法,然后返回结果集。此方法为上述的「预处理查询语句」的简化版,可直接在第二个参数使用 array 插入绑定参数执行。
$resultSet = $wrapper->executeQuery('SELECT * FROM user WHERE username = ?', array('jack'));
$user = $resultSet->fetchAssociative();
/* $user 值
array(
0 => array(
'id' => 1,
'username' => 'jack',
'gender' => 'man',
'update_time' => '2021-10-12'
)
)
*/
2
3
4
5
6
7
8
9
10
11
12
13
# fetchAllAssociative()
执行查询并将所有结果返回一个数组中。
因此,上面的查询语句还可以直接被简化为一次方法调用:
$resultSet = $wrapper->fetchAllAssociative('SELECT * FROM user WHERE username = ?', array('jack'));
// 结果同 executeQuery()->fetchAllAssociative() 中 $user 的值。
2
# fetchAllKeyValue()
执行查询并将前两列分别作为键和值提取到关联数组中。
$resultSet = $wrapper->fetchAllKeyValue('SELECT username, gender FROM user WHERE username = ?', array('jack'));
/* $resultSet 值
array(
'jack' => 'man'
)
*/
2
3
4
5
6
7
# fetchAllAssociativeIndexed()
执行查询并将数据作为关联数组获取,其中键代表第一列,值是其余列及其值的关联数组。
$users = $wrapper->fetchAllAssociativeIndexed('SELECT id, username, gender FROM users');
/*
array(
1 => array(
'username' => 'jack',
'gender' => 'man',
'update_time' => '2021-10-12'
)
)
*/
2
3
4
5
6
7
8
9
10
11
# fetchNumeric()
查询并返回第一行数据,形式以数字索引方式返回每一列。
$user = $wrapper->fetchNumeric('SELECT * FROM users WHERE username = ?', array('jack'));
/*
array(
0 => 'jwage',
1 => 'man',
2 => '2021-10-12'
)
*/
2
3
4
5
6
7
8
9
# fetchOne()
仅返回查询结果的第一行第一列的值。
$username = $wrapper->fetchOne('SELECT username FROM users WHERE id = ?', array(1));
echo $username; // jack
2
# fetchAssociative()
返回结果内第一行的关联数组形式的数据。
$users = $wrapper->fetchAssociative('SELECT * FROM users');
/*
array(
'id' => 1,
'username' => 'jack',
'gender' => 'man',
'update_time' => '2021-10-12'
)
*/
2
3
4
5
6
7
8
9
10
# delete()
删除查询操作,第一个参数为表名,第二个参数为 ['列名' => '列值']
。
<?php
$wrapper->delete('users', array('username' => 'jack'));
// 等同于执行DELETE FROM user WHERE username = ? ,参数列表为('jack')
2
3
# insert()
插入数据库一行,第一个参数为表名,第二个参数为对应数据。
$wrapper->insert('users', array('id' => 0, 'username' => 'jwage', 'gender' => 'woman', 'update_time' => '2021-10-17'));
// INSERT INTO user (id, username, gender, update_time) VALUES (?,?,?,?) (0,jwage,woman,2021-10-17)
2
# update()
更新数据库,使用给定数据更新匹配键值标识符的所有行。
<?php
$wrapper->update('user', array('username' => 'jwage'), array('id' => 1));
// UPDATE user (username) VALUES (?) WHERE id = ? (jwage, 1)
2
3