demo.php
<?php
go(function () {
$swoole_mysql = new Swoole\Coroutine\MySQL();
// 连接
$swoole_mysql->connect([
'host' => '127.0.0.1',
'port' => 3306,
'user' => 'root',
'password' => 'root',
'database' => 'test',
// 使用fetch/fetchAll获取结果集必须开启(v4.0 以上)
'fetch_mode' => true
]);
// 预处理
$stmt = $swoole_mysql->prepare("SELECT * FROM test WHERE id < ?");
// 执行
$rs = $stmt->execute([3]);
// 遍历结果集
while($ret = $stmt->fetch())
{
var_dump($ret);
}
// 开启事务
$swoole_mysql->begin();
// 直接执行 sql
$swoole_mysql->query('INSERT INTO test SET content = "insert something .."');
$swoole_mysql->query('UPDATE test SET content = "update something .." WHERE id = 1');
// 提交事务
$swoole_mysql->commit();
// 捕获异常&&事务回滚
// $swoole_mysql->rollback();
});
echo date('Y-m-d H:i:s') . ":go ..\n";