$db = new PDO ( 'mysql:host=' . $cfg ['hostanme'] . ';dbname=' . $cfg ['dbname'], $cfg ['username'], $cfg ['password'] ); $db->exec ( "set character_set_client = utf8" ); $db->exec ( "SET character_set_results =utf8" ); $db->exec ( "SET character_set_connection = utf8" ); $db->query ( "BEGIN" ); // 事务开始 $calories ="sa阿萨德"; $sth = $db->prepare(' INSERT INTO `test_user` values ( null,1, :calories);'); $sth->execute(array(':calories' => $calories )); $sths = $db->prepare(' INSERT INTO `test_users` values ( null,1, :calories);'); $sths->execute(array(':calories' => $calories )); //故意写错的 $lastid = $db->lastInsertId(); $sd = $sth->rowCount();
DROP PROCEDURE IF EXISTS pro_rep_shadow_rs;create procedure pro_rep_shadow_rs(out rtn int) begin -- 如果出现异常,会自动处理并rollback declare exit handler for sqlexception ROLLBACK ; -- 启动事务 start transaction; insert into test_user values(NULL,1,'啊是大三的'); insert into test_user VALUES(NULL,23,'sdsd',ss); --故意写错的 -- 运行没有异常,提交事务 commit; -- 设置返回值为1 set rtn=1; end;