原生操作

简介

DB 中 Swoft 提供了 selectselectOneupdateinsertdeletecursorstatementaffectingStatementunprepared 方法进行原生操作。

新增数据

$bool = DB::insert('INSERT INTO users (`id`, `name`) VALUES (?, ?)', [1, 'Swoft']);

参数说明:

  • $query:SQL 字符串
  • $bindings:绑定参数

如示例代码中,idname 的值通过 $bindings 参数传入,该操作返回 bool 值。

使用参数绑定可有效避免 SQL 注入。

删除数据

$deletedLines = DB::delete('DELETE FROM `users`');

参数说明:

  • $query:SQL 字符串
  • $bindings:绑定参数

该方法返回受影响的行数。

更新数据

$updatedLines = DB::update('UPDATE `users` SET `status` = ? WHERE `name` = ?', [1, 'Swoft']);

参数说明:

  • $query:SQL 字符串
  • $bindings:绑定参数

该方法返回受影响的行数。

查询数据

以下三种查询方式拥有相同的参数。

参数说明:

  • $query:SQL 字符串
  • $bindings:绑定参数
  • $useReadPdo:是否使用 库,默认为 true

Select

$users = DB::select('SELECT * FROM `users` WHERE `status` = ?', [1]);

select 方法返回一个数组,数组中的每个结果都是 array

SelectOne

如需查询一条数据可使用 selectOne 方法:

$sql= 'SELECT * FROM `users` WHERE `id` = ?';

$user = DB::selectOne($sql, [1]);

if ($user) {
    echo $user['name'];
}

selectOne 方法执行成功后返回一个数组。

Cursor 游标

游标用于快速遍历所有数据。

$sql= 'SELECT * FROM `users`';

$users = DB::cursor($sql);

foreach($users as $user){
	echo $user['name'];
}

底层采用 yield 机制获取数据,比 chunk 方法更快。

命名绑定

除使用 ? 进行参数绑定外,还可以使用如下方式进行命名绑定:

$results = DB::select('SELECT * FROM `user` WHERE `id` = :id', ['id' => 1]);

其它语句

Statement

数据库语句不存在返回值时,可以使用 statement 方法来执行:

$bool = DB::statement('DROP TABLE `users`');

该方法支持参数绑定,返回执行结果的 bool 值。

Unprepared

执行未预处理的 SQL 语句,也是真正意义上的原生语句。使用 unprepared 方法执行:

$unprepared = DB::unprepared('DROP TRIGGER IF EXISTS `sync_to_item_table`;');

if ($unprepared) {
    // TODO:
}

仅该方法支持多条 SQL,同时该方法不支持参数绑定,返回执行结果的 bool 值。

执行多条 SQL 时注意 ; 分号隔开。

上一页
下一页