Laravel 5.5 数据库 - 基本配置和操作

Myth丶恋晨 2022-05-10 10:06 363阅读 0赞

## 简介 ##

Laravel 中连接不同类型的数据库，对数据库进行增删改查操作都很简单，不论使用原生 SQL、还是查询构建器，还是 Eloquent ORM。

目前，Laravel 支持四种类型的数据库系统：

*  MySQL
 *  Postgres
 *  SQLite
 *  SQL Server

### 配置 ###

应用的数据库配置位于 config/database.php 文件。

需要注意的是：和运行环境相关的数据库配置在 .env 环境变量配置文件中。

.env 文件只会存在于本地的开发环境，禁止将其提交到版本库或线上环境。

这样，对于本地的开发环境，数据库配置文件 config/database.php 中的数据库相关配置就会随着 .env 文件中的对应配置项的改变而改变。而线上的生产环境中并没有 .env 文件，这样生产环境的数据库配置完全由 config/database.php 来决定。这也轻松实现了不同环境的不同配置。

在 config/database.php 文件中，可以定义所有的数据库连接，并指定哪个连接是默认连接。该文件中提供了所有支持数据库系统的配置示例。

默认情况下，Laravel 使用 MySQL 作为数据库引擎，并且示例配置已经为 Laravel Homestead 环境做好了设置（意思是说，如果你是用 Homestead 作为开发环境，就可以实现零配置使用），当然，你也可以按照需要为本地的数据库修改该配置（在 .env 中修改数据库配置）。

### SQLite 配置 ###

在项目根目录下使用 touch database/database.sqlite 命令创建好新的 SQLite 数据库之后，就可以使用数据库绝对路径配置环境变量指向这个新创建的数据库：

DB_CONNECTION=sqlite
    DB_DATABASE=/absolute/path/to/database.sqlite

SQLite 是一个轻量级的、遵守 ACID 标准的关系型数据库，它包含在一个相对小的 C 程序库中。与许多其它数据库管理系统不同，SQLite 不是一个客户端/服务器结构的数据库引擎，而是被集成在用户程序中。作为嵌入式数据库，是应用程序（如网页浏览器）在本地/客户端存储数据的常见选择。更多关于 SQLite 的信息请查看其官网：[http://www.sqlite.org/index.html][http_www.sqlite.org_index.html]

### 读写分离 ###

如果你希望使用一个数据库连接做查询，另一个数据库连接做插入、更新和删除，Laravel 中实现这种读写分离非常简单，不管你用的是原生 SQL，还是查询构建器，还是 Eloquent ORM，只要配置正确，合适的连接总是会被使用。

下面是一个读写分离配置的示例：

'mysql' => [
        'read' => [
            'host' => '192.168.1.1',
        ],
        'write' => [
            'host' => '196.168.1.2'
        ],
        'driver'    => 'mysql',
        'database'  => 'database',
        'username'  => 'root',
        'password'  => '',
        'charset'   => 'utf8',
        'collation' => 'utf8_unicode_ci',
        'prefix'    => '',
    ],

在配置数组中新增了两个键：read 和 write，这两个键对应值都有一个包含单个键“host”的数组，而其所映射的 IP 值分别就是读连接和写连接，读/写连接的其它数据库配置项都共用 mysql 的主数组配置。

如果我们想要覆盖主数组中的配置，只需要将相应配置项放到 read 和 write 数组中即可。

对于大部分应用来说都是读多写少，对这种情况，可以配置多个读连接，一个写连接。

'mysql' => [
        'driver' => 'mysql',
        'read' => [
            'host' => ['193.168.1.1', '194.168.1.1']
        ],
        'write' => [
            'host' => '196.168.1.2'
        ],
        //
    ]

Laravel 在读数据时会从提供的 IP 中随机选一个进行连接。实现原理感兴趣的同学可以查看 Illuminate\\Database\\Connectors\\ConnectionFactory 底层源码。

注：目前读写分离仅支持单个写连接。

sticky 选项

sticky 选项是一个可选的配置值，可用于在当前请求生命周期内允许立即读取写入数据库的记录。

如果 sticky 选项被启用并且一个”写”操作在当前生命周期内发生，则后续所有”读”操作都会使用这个”写”连接（前提是同一个请求生命周期内），这样就可以确保同一个请求生命周期内写入的数据都可以立即被读取到，从而避免主从延迟导致的数据不一致，是否启用这一功能取决于你。

当然，这只是一个针对分布式数据库系统中主从数据同步延迟的一个非常初级的解决方案，访问量不高的中小网站可以这么做，大流量高并发网站肯定不能这么干，主从读写分离本来就是为了解决单点性能问题，这样其实是把问题又引回去了，造成所有读写都集中到写数据库，对于高并发频繁写的场景下，后果可能是不堪设想的，但是话说回来，对于并发量不那么高，写操作不那么频繁的中小型站点来说，sticky 这种方式不失为一个初级的解决方案。

### 使用不同数据库连接 ###

使用多个数据库连接的时候，可以通过 DB 门面上的 connection 方法访问不同连接。传递给 connection 方法的 name 对应配置文件 config/database.php 中设置的某个连接：

$users = DB::connection('read')->select(...);

甚至还可以指定数据库和连接名，使用 :: 分隔：

$users = DB::connection('mysql::read')->select(...);

还可以使用连接实例上的 getPdo 方法访问底层原生的 PDO 实例：

$pdo = DB::connection('read')->getPdo();

## 原生 SQL ##

配置好数据库连接后，就可以使用 DB 门面来进行数据库操作。

DB 门面为每种操作提供了相应方法：select, update, insert, delete 和 statement。

### Select 查询 ###

运行一个最基本的查询，可以使用 DB 门面的 select 方法。

<?php
    
    namespace App\Http\Controllers;
    
    use Illuminate\Support\Facades\DB;
    use App\Http\Controllers\Controller;
    
    class UserController extends Controller
    {
        /**
         * 展示应用的用户列表.
         *
         * @return Response
         */
        public function index()
        {
            $users = DB::select('select * from users where active = ?', [1]);
    
            return view('user.index', ['users' => $users]);
        }
    }

select 方法的第一个参数是原生的 SQL 语句，第二个参数是需要绑定到 SQL 的参数绑定，通常，这些都是 where 子句约束中的值。

参数绑定可以避免 SQL 注入攻击（输入参数校验由实现方控制，用户无法传递任意查询参数）。

select 方法以数组的形式返回结果集，数组中的每一个结果都是一个 PHP stdClass 对象。

可以像下面这样访问结果集中的数据：

foreach ($users as $user) {
        echo $user->name;
    }

### 使用命名绑定 ###

除了使用 ? 占位符来代表参数绑定外，还可以使用命名绑定。

$results = DB::select('select * from users where id = :id', ['id' => 1]);

### 插入语句 ###

使用 DB 门面的 insert 方法执行插入语句。和 select 一样，该方法将原生 SQL 语句作为第一个参数，将参数绑定作为第二个参数：

DB::insert('insert into users (id, name) values (?, ?)', [1, 'jack']);

### 更新语句 ###

update 方法用于更新数据库中已存在的记录，该方法返回受更新语句影响的行数。

$affected = DB::update('update users set votes = 100 where name = ?', ['jack']);

### 删除语句 ###

delete 方法用于删除数据库中已存在的记录，返回被删除的行数。

$deleted = DB::delete('delete from users');

注：使用 delete 和 update 语句时，需要非常小心，如果条件设置不慎，导致的后果有可能是无法挽回的，比如不带条件的 delete 语句删除的将是数据表的所有记录！

### 通用语句 ###

有些数据库语句不返回任何值，比如新增表，修改表，删除表等，对于这种类型的操作，可以使用 DB 门面的 statement 方法。

DB::statement('drop table users');

### 监听查询事件 ###

如果你想要获取应用中每次 SQL 语句的执行，可以使用 listen 方法，该方法对查询日志和调试非常有用，你可以在服务提供者中注册查询监听器。

<?php
    
    namespace App\Providers;
    
    use Illuminate\Support\Facades\DB;
    use Illuminate\Support\ServiceProvider;
    
    class AppServiceProvider extends ServiceProvider
    {
        /**
         * Bootstrap any application services.
         *
         * @return void
         */
        public function boot()
        {
            DB::listen(function ($query) {
                // $query->sql
                // $query->bindings
                // $query->time
            });
        }
    
        /**
         * Register the service provider.
         *
         * @return void
         */
        public function register()
        {
            //
        }
    }

## 事务 ##

想要在一个数据库事务中运行一连串操作，可以使用 DB 门面的 transaction 方法。

使用 transaction 方法时不需要手动回滚或提交：如果事务闭包中抛出异常，事务将会自动回滚；如果闭包执行成功，事务将会自动提交。

DB::transaction(function () {
        DB::table('users')->update(['votes' => 1]);
        DB::table('posts')->delete();
    });

### 处理死锁 ###

数据库死锁指的是有两个或两个以上数据库操作相互依赖，一方需要等待另一方退出才能获取资源，但是如果没有一方提前退出，就会造成死锁，数据库事务容易造成的一个副作用就是死锁。

为此，transaction 方法接收一个可选参数作为第二个参数，用于定义死锁发生时事务的最大重试次数。如果尝试次数超出指定值，就抛出异常。

DB::transaction(function () {
        DB::table('users')->update(['votes' => 1]);    
        DB::table('posts')->delete();
    }, 5);

### 手动使用事务 ###

如果你想要手动开启事务，从而对回滚和提交有更好的控制，可以使用 DB 门面的 beginTransaction 方法：

// 开启事务
    DB::beginTransaction();

通过 rollBack 方法回滚事务：