您的位置：首页 > 数据库 > MySQL

pdo和原生态mysql连接实现事务

2014-11-26 19:33 309 查看

/*****************************pdo***********************************/

try{
$pdo->beginTransaction();//开启事务处理
$sql = "insert into `SlActivity` values(";
foreach($parameters as $key => $value){
$sql .= "'".$parameters[$key]."',";
}
$sql = rtrim($sql,",");
$sql .= ");";
$affected_rows=$pdo->exec($sql);
if(!$affected_rows)
throw new PDOException("插入数据失败");//那个错误抛出异常
$sql1="insert into SlLedger values(";
$sql1 .= "'1','2','3','4','5','6','7','8','9')";
$affected_rows=$pdo->exec($sql1);
if(!$affected_rows)
throw new PDOException("插入数据失败");
$pdo->commit();//交易成功就提交
}catch(PDOException $e){
echo $e->getMessage();
$pdo->rollback();

}

/****************************************************************/

/****************************mysql_connect***********************/

$userpass=$password;

$dbhost='192.168.7.192:3306';

$dbdatabase='shop';

$db_connect=mysql_connect($dbhost,$userName,$userpass);

if (!$db_connect || null == $db_connect){

die('Could not connect: ' . mysql_error());

}

mysql_select_db($dbdatabase,$db_connect);

mysql_query("BEGIN");

$sql1="insert into SlLedger values(";

$sql1 .= "'1','2','3','4','5','6','7','8','9')";

$result1=mysql_query($sql1);

$sql2 = "insert into `SlOrderDetail` values(";

$sql2 .= "'1','2','3','4','5','6','7','8')";

$result2 = mysql_query($sql2);

if($result1 && $result2){

mysql_query("COMMIT");

}else{

mysql_query("ROLLBACK");

}

mysql_query("END");

/****************************************************************/

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航