# 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();
1
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();
1
2
3
4
5

其中 $resultSetStatement 方法相似,此处的对象可能是 数据库语句对象 或 数据库结果对象(结果对象与语句对象的 fetchXXX() 部分一致)。

这里也可以使用命名标签,使用标签可以给相同参数处使用同一个标签:

$sql = "SELECT * FROM users WHERE gender = :name OR username = :name";
$stmt = $wrapper->getConnection()->prepare($sql);
$stmt->bindValue("name", "jack");
$resultSet = $stmt->executeQuery();
1
2
3
4

# 执行常规语句

执行常规语句为 statement 方式执行,此方法执行后只返回影响的行数,而不返回结果,适用于 UPDATE 等语句。

<?php
$count = $wrapper->executeStatement('UPDATE users SET username = ? WHERE id = ?', array('jwage', 1));
echo $count; // 1
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'
    )
)
*/
1
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 的值。
1
2

# fetchAllKeyValue()

执行查询并将前两列分别作为键和值提取到关联数组中。

$resultSet = $wrapper->fetchAllKeyValue('SELECT username, gender FROM user WHERE username = ?', array('jack'));

/* $resultSet 值
array(
    'jack' => 'man'
)
 */
1
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'
    )
)
*/
1
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'
)
*/
1
2
3
4
5
6
7
8
9

# fetchOne()

仅返回查询结果的第一行第一列的值。

$username = $wrapper->fetchOne('SELECT username FROM users WHERE id = ?', array(1));
echo $username; // jack
1
2

# fetchAssociative()

返回结果内第一行的关联数组形式的数据。

$users = $wrapper->fetchAssociative('SELECT * FROM users');

/*
array(
    'id' => 1,
    'username' => 'jack',
    'gender' => 'man',
    'update_time' => '2021-10-12'
)
*/
1
2
3
4
5
6
7
8
9
10

# delete()

删除查询操作,第一个参数为表名,第二个参数为 ['列名' => '列值']

<?php
$wrapper->delete('users', array('username' => 'jack'));
// 等同于执行DELETE FROM user WHERE username = ? ,参数列表为('jack')
1
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)
1
2

# update()

更新数据库,使用给定数据更新匹配键值标识符的所有行。

<?php
$wrapper->update('user', array('username' => 'jwage'), array('id' => 1));
// UPDATE user (username) VALUES (?) WHERE id = ? (jwage, 1)
1
2
3