PHP中执行MYSQL事务解决数据写入不完整等情况

PHP中执行MYSQL事务解决数据写入不完整等情况,第1张

近来稍有时间研究了下MYSQL中的事务 *** 作,在很多场合下很是适用,譬如在注册的时候需要初始化很多张关联表的时候,问答回复的时候需要至少同时 *** 作两张表,这些都会在某些时候只能成功更新一张表,而另外的SQL语句出现错误,正常的 *** 作会导致初始化了一张表

,其他的都木有能初始化,这个时候就会导致用户表里的用户信息已经执行插入,导致提示注册失败,但是用户已经注册了部分信息,这个时候需要程序员去数据库删除相应的数据是一个比较不好的事情。

因此这边考虑使用事务,事务可以进行模拟SQL *** 作,当所有的SQL都 *** 作成功的时候才进行SQL *** 作,只要有一个 *** 作失败就回滚当前事务的所有SQL *** 作,避免出现上面描述中出现的数据写入不完整等情况。

下面是鄙人写的一小段代码,欢迎大家参考和提出意见:

复制代码

代码如下:

/**

*

@todo

多条sql的事务处理

*

@param

$sqls

array

*

@return

boole

true/false

*/

public

function

doArraySqlActionsTran($password,$sqls){

$db

=

$this

->

doSqlLink($password)//打开数据库链接

$db

->

autocommit(FALSE)//设置为不自动提交,因为MYSQL默认立即执行

//获取SQL执行结果数组

for

($i=0$i<count($sqls)$i++){

$result[$i]

=

$db

->

query($sqls[$i])

}

//解析SQL执行结果数组

for

($j=0$j<count($result)$j++){

if

($result[$j]==FALSE){

$result[$j]='false'

}else{

$result[$j]='true'

}

}

//查找SQL结果数组中是否存在false结果集

if

(in_array('false',$result)){

$sqlResult=FALSE

}else{

$sqlResult==TRUE

}

//根据结果集进行数据库回滚或者执行 *** 作

if

($sqlResult==FALSE){

$db

->

rollback()//判断当执行失败时回滚

$return=FALSE//

正式环境中使用

//$return='ROOLBACK'//test

标记使用

}else{

$db

->

commit()//执行事务s

$return=TRUE//

正式环境中使用

//$return='COMMIT'//test

标记使用

}

$db->autocommit(true)

//设置为非自动提交——事务处理

$db->close()//关闭连接

return

$return

}

到此事务执行批量SQL *** 作基本完成,谢谢大家!

PHP与MYSQL事务处理

/*

MYSQL的事务处理主要有两种方法。

1、用begin,rollback,commit来实现

begin 开始一个事务

rollback 事务回滚

commit 事务确认

2、直接用set来改变mysql的自动提交模式

MYSQL默认是自动提交的,也就是你提交一个QUERY,它就直接执行!我们可以通过

set autocommit=0 禁止自动提交

set autocommit=1 开启自动提交

来实现事务的处理。

当你用 set autocommit=0 的时候,你以后所有的SQL都将做为事务处理,直到你用commit确认或rollback结束。

注意当你结束这个事务的同时也开启了个新的事务!按第一种方法只将当前的作为一个事务!

个人推荐使用第一种方法!

MYSQL中只有INNODB和BDB类型的数据表才能支持事务处理!其他的类型是不支持的!

***:一般MYSQL数据库默认的引擎是MyISAM,这种引擎不支持事务!如果要让MYSQL支持事务,可以自己手动修改:

方法如下:1.修改c:\appserv\mysql\my.ini文件,找到skip-InnoDB,在前面加上#,后保存文件。

2.在运行中输入:services.msc,重启mysql服务。

3.到phpmyadmin中,mysql->show engines(或执行mysql->show variables like 'have_%'),查看InnoDB为YES,即表示数据库支持InnoDB了。

也就说明支持事务transaction了。

4.在创建表时,就可以为Storage Engine选择InnoDB引擎了。如果是以前创建的表,可以使用mysql->alter table table_name type=InnoDB

或 mysql->alter table table_name engine=InnoDB来改变数据表的引擎以支持事务。

*/

/*************** transaction--1 ***************/

$conn = mysql_connect('localhost','root','root') or die ("数据连接错误!!!")

mysql_select_db('test',$conn)

mysql_query("set names 'GBK'")//使用GBK中文编码

//开始一个事务

mysql_query("BEGIN")//或者mysql_query("START TRANSACTION")

$sql = "INSERT INTO `user` (`id`, `username`, `sex`) VALUES (NULL, 'test1', '0')"

$sql2 = "INSERT INTO `user` (`did`, `username`, `sex`) VALUES (NULL, 'test1', '0')"//这条我故意写错

$res = mysql_query($sql)

$res1 = mysql_query($sql2)

if($res &&$res1){

mysql_query("COMMIT")

echo '提交成功。'

}else{

mysql_query("ROLLBACK")

echo '数据回滚。'

}

mysql_query("END")

/**************** transaction--2 *******************/

/*方法二*/

mysql_query("SET AUTOCOMMIT=0")//设置mysql不自动提交,需自行用commit语句提交

$sql = "INSERT INTO `user` (`id`, `username`, `sex`) VALUES (NULL, 'test1', '0')"

$sql2 = "INSERT INTO `user` (`did`, `username`, `sex`) VALUES (NULL, 'test1', '0')"//这条我故意写错

$res = mysql_query($sql)

$res1 = mysql_query($sql2)

if($res &&$res1){

mysql_query("COMMIT")

echo '提交成功。'

}else{

mysql_query("ROLLBACK")

echo '数据回滚。'

}

mysql_query("END")//事务处理完时别忘记mysql_query("SET AUTOCOMMIT=1")自动提交

/******************对于不支持事务的MyISAM引擎数据库可以使用表锁定的方法:********************/

//MyISAM &InnoDB 都支持,

/*

LOCK TABLES可以锁定用于当前线程的表。如果表被其它线程锁定,则造成堵塞,直到可以获取所有锁定为止。

UNLOCK TABLES可以释放被当前线程保持的任何锁定。当线程发布另一个LOCK TABLES时,或当与服务器的连接被关闭时,所有由当前线程锁定的表被隐含地解锁。

*/

mysql_query("LOCK TABLES `user` WRITE")//锁住`user`表

$sql = "INSERT INTO `user` (`id`, `username`, `sex`) VALUES (NULL, 'test1', '0')"

$res = mysql_query($sql)

if($res){

echo '提交成功。!'

}else{

echo '失败!'

}

mysql_query("UNLOCK TABLES")//解除锁定

MyISAM 是MySQL中默认的存储引擎,一般来说不是有太多人关心这个东西。决定使用什么样的存储引擎是一个很tricky的事情,但是还是值我们去研究一下,这里的文章只考虑 MyISAM 和InnoDB这两个,因为这两个是最常见的。

请看手册:

使用 transaction 方法 *** 作数据库事务,当发生异常会自动回滚,例如:

自动控制事务处理

Db::transaction(function(){

Db::table('think_user')->find(1)

Db::table('think_user')->delete(1)

})

也可以手动控制事务,例如:

// 启动事务

Db::startTrans()

try{

Db::table('think_user')->find(1)

Db::table('think_user')->delete(1)

// 提交事务

Db::commit()

} catch (\Exception $e) {

// 回滚事务

Db::rollback()

}

注意在事务 *** 作的时候,确保你的数据库连接是相同的。


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/sjk/9924952.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-03
下一篇 2023-05-03

发表评论

登录后才能评论

评论列表(0条)

保存