简介

本数据库类经过实际使用中大量改进优化，在保证安全的前提下提供了极高的执行效率。实际项目中， 我们大量用作亿级Mysql数据的快速迁移，转换处理。实路证明PHP的效率完全可以媲美ETL工具。

PHP处理大量数据时，你是否经常遇到内存溢出？使用本类库的迭代器方法不仅消耗极少的内存，页且效率极高，在我们公司的服务器上的数据迁移操作：

• 每秒处理2万条数据（批量5000的插入(insert into)或更新(replace Into)操作, 1秒能执行4条）
• 每分种处理100万条以上，
• 1千万的数据10分钟内处理完成。

创建实例

---

<?php
require_once './vendor/autoload.php';

// 在 ThinkPHP 中使用
// 单例，多次调用返回同一个实例（ThinkPHP 5.0），使用TP默认的数据库
$db = \Be\Db4\Tp50::getDb();
// ThinkPHP 5.1
$db = \Be\Db4\Tp51::getDb();
// 指定配置项, 在 ThinkPHP 的 database.php 配置中 增加一项 custom
$db = \Be\Db4\Tp51::getDb('database.custom');

// 创建数据库实例，每次调用返回一个新实例
$db = \Be\Db4\Tp51::newDb();

ThinkPHP 配置

---

字符串方式

"custom" => "mysql://username:password@192.168.0.1:3306/database#utf8",

数组方式

'custom' => [
    'type'           => 'mysql',
    'hostname'       => '192.168.0.1',
    'database'       => 'database',
    'username'       => 'username',
    'password'       => 'password',
],

事务处理示例

// 开启事务
$db->startTransaction();
try {
    // ...
    // 提交事务
    $db->commit();
} catch (\Exception $e) {
    // 回滚事务
    $db->rollback();
    // ...
}

读相关操作

// 返回用户信息对象
$user = $db->getObject('SELECT * FROM user WHERE id=1');

// 返回用户信息数组
$user = $db->getArray('SELECT * FROM user WHERE id=1');

// 返回符合条件的所有用户信息, 对象数组
$users = $db->getObjects('SELECT * FROM user WHERE age=18');

// 返回符合条件的所有用户信息, 二维数组
$users = $db->getArrays('SELECT * FROM user WHERE age=18');

// 返回单个值
$count = $db->getValue('SELECT COUNT(*) FROM user WHERE age=18');

// 返回多个值，数组
$names = $db->getValues('SELECT name FROM user WHERE age=18');

// 返回键值对, 带键名的数组（id 作为键名，name 作为值）
$idNameKeyValues = $db->getKeyValues('SELECT id, name FROM user WHERE age=18');

// 返回键值对, 带键名的数组（id 作为键名，用户信息数组 作为值）
$idUserKeyArrays = $db->getKeyArrays('SELECT id, name, age FROM user WHERE age=18');

// 返回键值对, 带键名的数组（id 作为键名，用户信息对像 作为值）
$idUserKeyObjects = $db->getKeyValues('SELECT id, name, age FROM user WHERE age=18');

迭代器

// 以迭代器形式返回符合条件的所有用户信息，对象数组，用作处理大量数据，消耗较少内存
$users = $db->getYieldObjects('SELECT * FROM user WHERE age=18');

// 以迭代器形式返回符合条件的用户信息，二维数组，用作处理大量数据，消耗较少内存
$users = $db->getYieldArrays('SELECT * FROM user WHERE age=18');

占位符

$users = $db->getObjects('SELECT * FROM user WHERE age=?', [18]);
$users = $db->getObjects('SELECT * FROM user WHERE age>=? AND age<=?', [18, 25]);
$users = $db->getObjects('SELECT * FROM user WHERE name=?', ['abc']);
$users = $db->getObjects('SELECT * FROM user WHERE name=? AND age=?', ['abc', 18]);

写相关操作

---

对象插入

$user = new stdClass();
$user->name = 'abc';
$user->age = 18;
$db->insert('user', $user);
$userId = $db->getLastInsertId();

数组插入

$user = [];
$user['name'] = 'abc';
$user['age'] = 18;
$db->insert('user', $user);
$userId = $db->getLastInsertId();

批量插入

$users = [];
$users[] = $user1;
$users[] = $user2;
// ...
$db->insertMany('user', $users);

快速插入，未预编译SQL

$db->quickInsert('user', $user);
$db->quickInsertMany('user', $users);

更新用户资料

$user->id = 1;
$db->update('user', $user);
$db->update('user', $user, 'id');

新增或更新（主键冲突时更新）

$db->replace('user', $user);
$db->replaceMany('user', $users);

$db->quickReplace('user', $user);
$db->quickReplaceMany('user', $users);

• quick 开头的函数均为快速处理方法，未预编译SQL

其它

---

拼接SQL, 防注入

$search = "abc'abc";
$sql = 'SELECT * FROM ' . $db->quoteKey('user') . ' WHERE ' . $db->quoteKey('name') . '=' . $db->quoteValue($search)
$user = $db->getObject($sql);

// 对等SQL(MySQL): SELECT * FROM `user` WHERE `name` = 'abc\'abc'
// 对等SQL(Oracle): SELECT * FROM "user" WHERE "name" = 'abc\'\'abc'

拼接SQL, 防注入, escape 方法

$search = "abc'abc";
$sql = 'SELECT * FROM ' . $db->quoteKey('user') . ' WHERE ' . $db->quoteKey('name') . '=\'' . $db->escape($search) . '\''
$user = $db->getObject($sql);

// 对等SQL(MySQL): SELECT * FROM `user` WHERE `name` = 'abc\'abc'
// 对等SQL(Oracle): SELECT * FROM "user" WHERE "name" = 'abc\'\'abc'

执行 SQL

$sql = 'UPDATE user SET age=20 WHERE name=\'abc\''
$db->query($sql);


$sql = 'UPDATE user SET age=? WHERE name=?'
$db->query($sql, [20, 'abc']);

迭代器方法

迭代器方法格式为 getYield***()

迭代器方法因为游标长时间未释放，为了实现在迭代期间的SQL操作，迭代器方法重建了一个新的数据库连接，迭代处理完成后，该连接释放。

因此，迭代器方法如果用在了事务中，不应该操作事务相关的数据，MYSQL 的默认事务隔离级别使得迭代器方法读取不到事务中尚未提交的数据。

当MYSQL的事务隔离级别为 READ-UNCOMMITTED(读取未提交) 时，迭代器方法才可以读取到未提交的数据。