快速开始

    hyperf/database 组件是基于 衍生出来的组件，我们对它进行了一些改造，从设计上是允许用于其它 PHP-FPM 框架或基于 Swoole 的框架中的，而在 Hyperf 里就需要提一下 hyperf/db-connection 组件，它基于 实现了数据库连接池并对模型进行了新的抽象，以它作为桥梁，Hyperf 才能把数据库组件及事件组件接入进来。

    其它框架

    默认配置如下，数据库支持多库配置，默认为 default。

    1. <?php
    3. return [
    4.     'default' => [
    5.         'driver' => env('DB_DRIVER', 'mysql'),
    6.         'host' => env('DB_HOST', 'localhost'),
    7.         'database' => env('DB_DATABASE', 'hyperf'),
    8.         'username' => env('DB_USERNAME', 'root'),
    9.         'password' => env('DB_PASSWORD', ''),
    10.         'charset' => env('DB_CHARSET', 'utf8'),
    11.         'collation' => env('DB_COLLATION', 'utf8_unicode_ci'),
    12.         'prefix' => env('DB_PREFIX', ''),
    13.         'pool' => [
    14.             'min_connections' => 1,
    15.             'connect_timeout' => 10.0,
    16.             'wait_timeout' => 3.0,
    17.             'heartbeat' => -1,
    18.             'max_idle_time' => (float)env('DB_MAX_IDLE_TIME', 60),
    19.         ]
    20.     ],
    21. ];

    有时候用户需要修改 PDO 默认配置，比如所有字段需要返回为 string。这时候就需要修改 PDO 配置项 ATTR_STRINGIFY_FETCHES 为 true。

    有时候你希望 SELECT 语句使用一个数据库连接，而 INSERT，UPDATE，和 DELETE 语句使用另一个数据库连接。在 Hyperf 中，无论你是使用原生查询，查询构造器，或者是模型，都能轻松的实现

    1. <?php
    3. return [
    4.     'default' => [
    5.         'driver' => env('DB_DRIVER', 'mysql'),
    6.         'read' => [
    8.         ],
    9.         'write' => [
    10.             'host' => ['196.168.1.2'],
    11.         ],
    12.         'sticky'    => true,
    13.         'database' => env('DB_DATABASE', 'hyperf'),
    14.         'username' => env('DB_USERNAME', 'root'),
    15.         'password' => env('DB_PASSWORD', ''),
    16.         'charset' => env('DB_CHARSET', 'utf8'),
    17.         'collation' => env('DB_COLLATION', 'utf8_unicode_ci'),
    18.         'prefix' => env('DB_PREFIX', ''),
    19.         'pool' => [
    20.             'min_connections' => 1,
    21.             'connect_timeout' => 10.0,
    22.             'wait_timeout' => 3.0,
    23.             'heartbeat' => -1,
    24.             'max_idle_time' => (float) env('DB_MAX_IDLE_TIME', 60),
    25.         ],
    26.     ],
    27. ];

    注意在以上的例子中，配置数组中增加了三个键，分别是 read， write 和 sticky。 read 和 write 的键都包含一个键为 host 的数组。而 read 和 write 的其他数据库都在键为 mysql 的数组中。

    如果你想重写主数组中的配置，只需要修改 read 和 write 数组即可。所以，这个例子中： 192.168.1.1 将作为 「读」 连接主机，而 192.168.1.2 将作为 「写」 连接主机。这两个连接会共享 mysql 数组的各项配置，如数据库的凭据（用户名 / 密码），前缀，字符编码等。

    sticky 是一个 可选值，它可用于立即读取在当前请求周期内已写入数据库的记录。若 sticky 选项被启用，并且当前请求周期内执行过 「写」 操作，那么任何 「读」 操作都将使用 「写」 连接。这样可确保同一个请求周期内写入的数据可以被立即读取到，从而避免主从延迟导致数据不一致的问题。不过是否启用它，取决于应用程序的需求。

    配置好数据库后，便可以使用 Hyperf\DbConnection\Db 进行查询。

    Select 查询

    1. <?php
    3. use Hyperf\DbConnection\Db;
    5. $users = Db::select('SELECT * FROM `user` WHERE gender = ?',[1]);
    7. foreach($users as $user){
    8.     echo $user->name;
    9. }

    可以使用 Db 的 insert 方法来执行 insert 语句。与 select 一样，该方法将原生 SQL 查询作为其第一个参数，并将绑定数据作为第二个参数：

    运行更新语句

    update 方法用于更新数据库中现有的记录。该方法返回受该语句影响的行数：

    1. <?php
    2. use Hyperf\DbConnection\Db;
    4. $affected = Db::update('update user set name = ? where id = ?', ['John', 1]);

    你可以使用 Db 的 transaction 方法在数据库事务中运行一组操作。如果事务的闭包 Closure 中出现一个异常，事务将会回滚。如果事务闭包 Closure 执行成功，事务将自动提交。一旦你使用了 transaction ， 就不再需要担心手动回滚或提交的问题：

    1. <?php
    2. use Hyperf\DbConnection\Db;
    4. Db::transaction(function () {
    5.     Db::table('user')->update(['votes' => 1]);
    7.     Db::table('posts')->delete();

    手动使用事务

    如果你想要手动开始一个事务，并且对回滚和提交能够完全控制，那么你可以使用 Db 的 beginTransaction, commit, :