
2、配置php.ini
extension=php_gd2.dll
extension=php_mbstring.dll
extension=php_mysql.dll
extension=php_mysqli.dll
把上面四个。dll的最前面的;去掉
二、php表单提交至数据库的实现过程
1、login.php页面
<SPAN style="FONT-SIZE: 14px"><html>
<FORM method=post action=add.php>
Name: <INPUT name=username><BR>
Email: <INPUT name=email><BR>
<INPUT value=提交 type=submit name=submit>
</FORM>
</SPAN>
2、add.php页面
<SPAN style="FONT-SIZE: 14px"><?php
include("conn.php");
?>
<?php
if(isset($_POST["submit"]))
{
$sql = "insert into users(username, email) values('$_POST[username]', '$_POST[email]')"
mysqli_query($conn, $sql);
echo "添加成功"
}
?></SPAN>
3、conn.php页面
<SPAN style="FONT-SIZE: 14px"><?php
$conn = new mysqli("localhost", "root", "159357");
$conn->select_db("db_test");
//mysql_query("set name 'gb2312'");
$conn->set_charset("utf8");
?></SPAN>
一、什么是事务?事务就是一段sql语句的批处理,但是这个批处理是一个atom(原子) ,不可分割,要么都执行,要么回滚(rollback)都不执行。
通俗点举个例子:
有一天张三给李四要转钱,那么银行的数据库就要把张三的账户减去1000元(-1000),李四的账户就要增加1000元(+1000),这两个更新语句必须作为一个整体来执行,不然就会出现张三账户扣掉了1000元钱而李四账户并没有增加1000元钱,然而这种情况很难找出原因,所以就需要这俩个 *** 作作为一个整体要么一起失败都没有执行,要么就一起成功一个增加1000元、一个减少1000元,这就是事务在实际中的具体体现。
二、事务的四个特性
1)、原子性(atomicity):原子性是指整个数据库事务是不可分割的工作单位
2)、一致性(consistency):一致性指事务将数据库从一种状态转变为下一种一致的状态。在事务开始之前和事务结束之后,数据库的完整性约束没有被破坏。
3)、隔离性(isolation):一个事务的影响在该事务提交之前对其他事务都不可见---通过锁来实现。
4)、持久性(durability):事务一旦提交,其结果就是永久性的 。
三、务依赖InnoDB存储引擎
事务的执行是需要存储引擎来支持的,那么存储引擎是什么呢?
存储引擎顾名思义就是数据库如何存储数据、如何为存储的数据建立索引和如何更新、查询数据等技术的实现方法。因为在关系数据库中数据的存储是以表的形式存储的,所以存储引擎也可以称为表类型(即存储和 *** 作此表的类型)。
主要存储引擎:Myisam、InnoDB、MEMORY、Archive、BDB等,其中MyISAM与InnoDB的区别如下:
修改存储引擎的方法为,如图:
1、首先右键打开设计表菜单
2、选择“选项”选项卡,在第一行中的引擎下拉菜单中选择InnoDB即可;
四、执行事务的三步骤
我们还是继续刚才的转账的案例,
1、开启事务:
Start transaction
2、执行sql语句组
update account set money=money+1000 where id=2
update account set money=money-1000 where id=1
3、commit(提交事务)或rollback(回滚事务)
注意:当一个事务commit或rollback就结束了,下次还要重新开启事务;
五、在TP5中使用事务
TP5中使用事务有两种方式,一种为自动事务,一种为手动事务。
自动事务:通过执行SQL语句过程中是否抛出异常来决定事务是提交执行还是回滚处理,如下例所示,如果向test_a和test_b两个表中插入语句。
如果test_b表中id字段为自增的主键时,并且含有主键为1的数据时,插入语句会出现执行错误,TP5框架会抛出异常,如图:
此时,如果没有使用事务或者使用事务而没有使用InnoDB的存储引擎时,数据库的结果就会在test_a表中插入一条ID为13的数据,而test_b表却没有插入成功,如图所示:
如果使用事务并且也应用了InnoDB的存储引擎的时候,数据表中的数据会没有变化,ID为13的记录不会增加到test_a表中,如下图
自动事务最大的优势为代码简洁,但只能通过是否抛出异常来进行判断事务是否回滚,用法有一些限制。但手动事务即可以通过在SQL语句上增加try{}catche(){}语句来捕获异常来判断是否回滚事务,也可以通过代码的返回值来判断是否提交事务,相比较来说手动事务更加自由和方便。
手动事务:
方法一:通过是否能够捕获到异常来判断是否回滚事务
方法二:通过语句执行结果来判断是否回滚事务
最终结果如下:
六、最后总结
通过比较两种不同方式来实现事务,个人推荐采用第二种并且通过捕获异常的方式来处理事务,原因其实很简单,这样执行首先可以保证事务正常运行,而且还可以通过异常的处理保证程序的顺利执行,提升代码的健壮性,并且还可以根据实际业务情况选择通过判断语句返回值来决定是否回滚事务,这样更提升了代码的灵活性。
写在最后:
在TP的事务代码调用中,既可以用DB类来调用也可以使用模型类来调用,对事务本身毫无影响,其实就是利用数据库的类将原生的事务语句加入到SQL中去执行而已。
thinkphp批量更新数据可以参考如下三种方法:方法一:
//批量修改 data二维数组 field关键字段 参考ci 批量修改函数 传参方式
function batch_update($table_name='',$data=array(),$field=''){
if(!$table_name||!$data||!$field){
return false
}else{
$sql='UPDATE '.$table_name
}
$con=array()
$con_sql=array()
$fields=array()
foreach ($data as $key =>$value) {
$x=0
foreach ($value as $k =>$v) {
if($k!=$field&&!$con[$x]&&$x==0){
$con[$x]=" set {$k} = (CASE {$field} "
}elseif($k!=$field&&!$con[$x]&&$x>0){
$con[$x]=" {$k} = (CASE {$field} "
}
if($k!=$field){
$temp=$value[$field]
$con_sql[$x].= " WHEN '{$temp}' THEN '{$v}' "
$x++
}
}
$temp=$value[$field]
if(!in_array($temp,$fields)){
$fields[]=$temp
}
}
$num=count($con)-1
foreach ($con as $key =>$value) {
foreach ($con_sql as $k =>$v) {
if($k==$key&&$key<$num){
$sql.=$value.$v.' end),'
}elseif($k==$key&&$key==$num){
$sql.=$value.$v.' end)'
}
}
}
$str=implode(',',$fields)
$sql.=" where {$field} in({$str})"
$res=M($table_name)->execute($sql)
return $res
}
//测试
function test(){
$update_array=array()
for ($i=2$i <7 $i++) {
$data=array()
$data['id']=$i
$data['memeber_type']=2
$data['memeber_type_state']=1
$update_array[]=$data
}
$res=$this->batch_update('yl_member',$update_array,id)
var_dump($res)
}
方法二:
即是循环一条一条的更新记录。一条记录update一次,这样性能很差,也很容易造成阻塞。
那么能不能一条sql语句实现批量更新呢?mysql并没有提供直接的方法来实现批量更新,但是可以用点小技巧来实现。
UPDATE categories
SET display_order = CASE id
WHEN 1 THEN 3
WHEN 2 THEN 4
WHEN 3 THEN 5
END
WHERE id IN (1,2,3)
这句sql的意思是,更新display_order 字段,如果id=1 则display_order 的值为3,如果id=2 则 display_order 的值为4,如果id=3 则 display_order 的值为5。
即是将条件语句写在了一起。
这里的where部分不影响代码的执行,但是会提高sql执行的效率。确保sql语句仅执行需要修改的行数,这里只有3条数据进行更新,而where子句确保只有3行数据执行。
如果更新多个值的话,只需要稍加修改:
UPDATE categories
SET display_order = CASE id
WHEN 1 THEN 3
WHEN 2 THEN 4
WHEN 3 THEN 5
END,
title = CASE id
WHEN 1 THEN 'New Title 1'
WHEN 2 THEN 'New Title 2'
WHEN 3 THEN 'New Title 3'
END
WHERE id IN (1,2,3)
实际运用
$display_order = array(
1 =>4,
2 =>1,
3 =>2,
4 =>3,
5 =>9,
6 =>5,
7 =>8,
8 =>9
)
$ids = implode(',', array_keys($display_order))
$sql = "UPDATE categories SET display_order = CASE id "
foreach ($display_order as $id =>$ordinal) {
$sql .= sprintf("WHEN %d THEN %d ", $id, $ordinal)
}
$sql .= "END WHERE id IN ($ids)"
echo $sql
方法二不建议使用。
方法三:
/*
* @param $saveWhere :想要更新主键ID数组
* @param $saveData :想要更新的ID数组所对应的数据
* @param $tableName : 想要更新的表明
* @param $saveWhere : 返回更新成功后的主键ID数组
* */
public function saveAll($saveWhere,&$saveData,$tableName){
if($saveWhere==null||$tableName==null)
return false
//获取更新的主键id名称
$key = array_keys($saveWhere)[0]
//获取更新列表的长度
$len = count($saveWhere[$key])
$flag=true
$model = isset($model)?$model:M($tableName)
//开启事务处理机制
$model->startTrans()
//记录更新失败ID
$error=[]
for($i=0$i<$len$i++){
//预处理sql语句
$isRight=$model->where($key.'='.$saveWhere[$key][$i])->save($saveData[$i])
if($isRight==0){
//将更新失败的记录下来
$error[]=$i
$flag=false
}
//$flag=$flag&&$isRight
}
if($flag ){
//如果都成立就提交
$model->commit()
return $saveWhere
}elseif(count($error)>0&count($error)<$len){
//先将原先的预处理进行回滚
$model->rollback()
for($i=0$i<count($error)$i++){
//删除更新失败的ID和Data
unset($saveWhere[$key][$error[$i]])
unset($saveData[$error[$i]])
}
//重新将数组下标进行排序
$saveWhere[$key]=array_merge($saveWhere[$key])
$saveData=array_merge($saveData)
//进行第二次递归更新
$this->saveAll($saveWhere,$saveData,$tableName)
return $saveWhere
}
else{
//如果都更新就回滚
$model->rollback()
return false
}
}
在测试方法中调用:
public function test(){
//要更新的数据表的主键数组
$where['ID']=array(70,73,74,80,83)
//ID主键数组对应的待更新数据
$save=array(
array('School'=>'DK Univisity01','isExport'=>0),
array('School'=>'DK Univisity02','isExport'=>0),
array('School'=>'DK Univisity03','isExport'=>0),
array('School'=>'DK Univisity04','isExport'=>0),
array('School'=>'','isExport'=>0),
// array('School'=>' Univisity05','isExport'=>0),
)
$f=$this->saveAll($where,$save,'want')
if(count($f['ID'])>0){
//返回更新成功的ID数组
echo "This is success :</br>"
dump($f)
echo 'ok'
}else{
//更新失败 *** 作
echo "This is failed :</br>"
dump($f)
echo 'error'
}
}
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)