try {
$db->setAttribute(PDO::ATTR_AUTOCOMMIT, false);
$db->beginTransaction(); // 开启一个事务
$row = null;
$sql = 'INSERT INTO `reguser` (`username`, `password`) VALUES (' . $db->quote($username) . ',' . $db->quote($password) . ')';
$row = $db->exec($sql);
if (!$row)
throw new PDOException('注册失败1');
$id = $db->lastInsertId();
$sql = 'INSERT INTO `account` (`partner_id`, `partner1`) VALUES (' . $db->quote($id) . ',' . $db->quote($partner) . ')';
$row = $db->exec($sql);
if (!$row)
throw new PDOException('注册失败2');
$db->commit(); //提交事务
} catch (PDOException $e) {
$db->rollback(); // 执行失败,事务回滚
api_error(array('msg' => '注册失败'));
}
阅读(1095) | 评论(0) | 转发(0) |