一个简洁的PHP操作Access类

/*

FileName:cls_access.php

Summary: Access数据库操作类

*************************************

使用范例:

========================

$databasepath='D:/wwwroot/cef/www/class/testdb.mdb';

//或者$databasepath='testdb.mdb';

$dbusername='';

$dbpassword='';

require_once('cls_access.php');

$access=new Access($databasepath,$dbusername,$dbpassword);

print_r($access->getlist("SELECT TOP 5 * FROM `Result` WHERE `ResultNo` < 12 ORDER BY `ResultNo` DESC"));

echo $access->num_rows("update `conner` set `connerip` = '222.35.142.101' where `connerno` < 83");

========================

*/

 

class Access{

    var $databasepath,$constr,$dbusername,$dbpassword,$link;

    function Access($databasepath,$dbusername,$dbpassword){

        $this->databasepath=$databasepath;

        $this->username=$dbusername;

        $this->password=$dbpassword;

        $this->connect();

    }

function connect(){

    $this->constr='DRIVER={Microsoft Access Driver (*.mdb)};DBQ='.realpath($this->databasepath).';';

    $this->link=odbc_connect($this->constr,$this->username,$this->password,SQL_CUR_USE_ODBC);

    if(!$this->link) echo "数据库连接失败!";

    return $this->link;

}

 

function query($sql){     //直接运行SQL,可用于更新、删除数据

    return @odbc_exec($this->link,$sql);

}

 

function fetch_array($query){     //取得当前指针处记录

    return odbc_fetch_array($query);

}

 

function fetch_row($query){    //基本同fetch_array(),但只有数字索引

    return odbc_fetch_row($query);

}

 

function num_rows($sql){    //返回SQL查询影响到的行的数目

    return odbc_num_rows($this->query($sql));

}

 

function close(){    //关闭数据库连接函数

    odbc_close($this->link);

}

 

function getlist($sql){    //取得记录列表

    $query=$this->query($sql);

    $recordlist=array();

    while ($row=$this->fetch_array($query)){

        $recordlist[]=$row;

    }

    return $recordlist;

}

}

这个类用的是ODBC,并不想网上说的要用ODBC数据源。我直接新建一个*.mdb文件就可以使用。

 

再附上部分常用COM方式操作Access代码:

$db = $_SERVER['DOCUMENT_ROOT'].'/zhuanti/ugdkfjlsg54356k6546jk654gfslkg6544s.mdb';

$conn = new COM('ADODB.Connection') or die('can not start Active X Data Objects');

$conn->Open("DRIVER={Microsoft Access Driver (*.mdb)}; DBQ=$db");

JS调用页js.php

include_once('conn.php');

$rs = $conn->Execute("SELECT TOP 3 * FROM userstar where chk = 1 ORDER BY id DESC");

$idgb=1;

while(!$rs->EOF){

    $gbinf[$idgb]['id'] = $rs->Fields['id']->Value;

    $gbinf[$idgb]['usname'] = $rs->Fields['usname']->Value;

    $gbinf[$idgb]['usage'] = $rs->Fields['usage']->Value;

    $gbinf[$idgb]['usprovince'] = $rs->Fields['usprovince']->Value;

    $gbinf[$idgb]['usfile'] = $rs->Fields['usfile']->Value;

    $gbinf[$idgb]['thumb'] = $rs->Fields['thumb']->Value;

    $gbinf[$idgb]['usmessage'] = $rs->Fields['usmessage']->Value;

    $rs->MoveNext();

    $idgb++;

}

$rs->Close();

$rs = null;

$uhtml='';

$uhtml.='<table border="0" align="center"><tr>';

for ($i=1; $i<4; $i++){

    $uhtml.='<td width="240" align="center">';

    if ($gbinf[$i]['usfile']){

        $uhtml.='<a href="/index.php" target="_blank" title="'.$gbinf[$i]['usname'].'"><img src="/'.$gbinf[$i]['thumb'].'" /></a><br />'.$gbinf[$i]['usprovince'].'&nbsp;'.$gbinf[$i]['usname'];

        if ($gbinf[$i]['usage'] != 0){

            $uhtml.='&nbsp;('.$gbinf[$i]['usage'].'岁)<br />';

        }

       $uhtml.='<div style="width:180px; height:40px; overflow:hidden; text-align:left"><a href="/index.php" target="_blank" title="'.$gbinf[$i]['usmessage'].'" style="line-height:20px; font-size:12px">'.$gbinf[$i]['usmessage'].'</a></div>';

    }

    $uhtml.='</td>';

}

$uhtml.='</tr></table>';

echo "document.write('".$uhtml."')";

 

又一段代码例子,以本文件路径确定数据库路径:

/*

===========================

数据库连接配置

*/

$db = getcwd().'\images\90d\90dicr_os6546oftff_ic543e_cces_4535s.mdb';

$conn = new COM('ADODB.Connection') or die('can not start Active X Data Objects');

$conn->Open("DRIVER={Microsoft Access Driver (*.mdb)}; DBQ=$db");

/*

===========================

*/

//print_r($_POST);

if ($_POST['name'] && $_POST['tel'] && $_POST['addr'] && $_POST['email'] && $_POST['goal'] && $_POST['high'] && $_POST['weight'] && $_POST['message'])

{

$addsql = "INSERT INTO d90usr (`name`, `tel`, `addr`, `email`, `goal`, `high`, `weight`, `message`) VALUES ('".$_POST['name']."', '".$_POST['tel']."', '".$_POST['addr']."', '".$_POST['email']."', '".$_POST['goal']."', '".$_POST['high']."', '".$_POST['weight']."', '".strip_tags($_POST['message'])."')";

//echo '<hr />'.$addsql;

$rsadd = $conn->Execute($addsql);

echo '<script type="text/javascript">alert("报名成功,请等待工作人员与您联系!");</script>';

echo '<p align="center"><h1>恭喜您报名成功,请等待工作人员与您联系!</h1></p>';

echo '<p align="center"><a href="90d.php">返回活动首页</a>&nbsp;&nbsp;<a href="/">返回商城首页</a></p>';

}

简洁的PHP操作SQLite类

SQLite是一款轻型的数据库" title="数据库" >数据库,是遵守ACID的关联数据库" title="数据库" >数据库管理系统,它的设计目标是嵌入式的,而且目前已经在很嵌入式产品中使用了它,它占用资源非常的低,在嵌入式设备中,可能只需要几百K的内存就够了。它能够支持Windows/Linux/Unix等等主流的操作系统,同时能够跟很程序言相结合,比如Tcl、PHP、Java等,还有ODBC接口,同样比起Mysql、PostgreSQL这两款开源世界著名的数据库" title="数据库" >数据库管理系统来讲,它的处理速度比他们都快。

这里为大家提供一个简洁的PHP操作SQLite

<?php

/***

//应用举例

require_once('cls_sqlite.php');

//创建实例

$DB=new SQLite('blog.db'); //这个数据库" title="数据库" >数据文件名字任意

//创建数据库" title="数据库" >数据库表。

$DB->query("create table test(id integer primary key,title varchar(50))");

//接下来添加数据

$DB->query("insert into test(title) values('小屋')");

$DB->query("insert into test(title) values('蓝雨')");

$DB->query("insert into test(title) values('Ajan')");

$DB->query("insert into test(title) values('sjolzy')");

//读取数据

print_r($DB->getlist('select * from test order by id desc'));

//更新数据

$DB->query('update test set title = "三大" where id = 9');

***/

 

class SQLite

{

    function __construct($file){

        try{

            $this->connection=new PDO('sqlite:'.$file);

        }catch(PDOException $e){

            try{

                $this->connection=new PDO('sqlite2:'.$file);

            }catch(PDOException $e){

                exit('error!');

            }

        }

    }


    function __destruct(){

        $this->connection=null;

    }

class="Apple-style-span" style="color: rgb(165, 42, 42); ">    functionquery($sql){ //直接运行SQL,可用于更新、删除数据

        return $this->connection->query($sql);

    }

class="Apple-style-span" style="color: rgb(165, 42, 42); ">    function getlist($sql){ //取得记录列表

        $recordlist=array();

        foreach($this->query($sql) as $rstmp){

            $recordlist[]=$rstmp;

        }

        return $recordlist;

    }

class="Apple-style-span" style="color: rgb(165, 42, 42); ">    function Execute($sql){

        return $this->query($sql)->fetch();

    }

class="Apple-style-span" style="color: rgb(165, 42, 42); ">    function RecordArray($sql){

        return $this->query($sql)->fetchAll();

    }

class="Apple-style-span" style="color: rgb(165, 42, 42); ">    function RecordCount($sql){

        return count($this->RecordArray($sql));

    }

    function RecordLastID(){

        return $this->connection->lastInsertId();

    }

}

?>

转载相关 PHP 配置说明

1. 先测试 PHP 能否连接sqlite 数据库" title="数据库" >数据库:

建立一个php文件

<?php

$conn  =  sqlite_open('test.db');

?>

测试这个文件能否正常运行。

如果没有能正常加载sqlite模块,就可能出现这样的错误

Fatal error: Call to undefined functionsqlite_open() in C:\Apache\Apache2\htdocs\test.php on line 2

解决办法如下:

2. 打开 php.ini 文件,将以下三行前面的分号删除:

;extension=php_sqlite.dll

;extension=php_pdo.dll

;extension=php_pdo_sqlite.dll

重新启动web服务器

PDO多种方式取得查询结果

PDO最大的特点之一是它的灵活性,本节将介绍如何取得查询结果,包括:

数组(数值或关联数组);

字符串(单列的结果集);

对象;

回调函数。

1.快取一行

FetchColumn是为应用程序取得一个仅包含单列的数据,代码如下:

$u = $db->query(“SELECT id FROM users WHERE login=
‘login’ AND password=‘password’”);
fetch(PDO::FETCH_COLUMN)
if ($u->fetchColumn()) { //返回一个字符串
//登录成功
} else {
//验证失败
}
?>

2.取得一个标准对象

还可以将取得的一行作为一个标准类stdClass的对象实例,其中列名=属性名。

$res = $db->query(“SELECT * FROM foo”);
while ($obj = $res->fetch(PDO::FETCH_OBJ)) {
// $obj == instance of stdClass
}
?>

3.存取为一个类

PDO允许将结果保存为一个类,例子如下:

$res = $db->query(“SELECT * FROM foo”);
$res->setFetchMode(
PDO::FETCH_CLASS,
“className”,
array(‘optional’=‘Constructor Params’)
);
while ($obj = $res->fetch()) {
// $obj == instance of className
}
?>

4.从一个类取得常量

PDO允许查询的结果可以被用来生成一个目的类。

$res = $db->query(“SELECT * FROM foo”);
$res->setFetchMode(
PDO::FETCH_CLASS |
PDO::FETCH_CLASSTYPE
);
while ($obj = $res->fetch()) {
// $obj == instance of class who’s name is
// found in the value of the 1st column
}
?>

5.存取为一个对象

PDO还允许获取数据到一个已经存在的对象。

$u = new userObject;
$res = $db->query(“SELECT * FROM users”);
$res->setFetchMode(PDO::FETCH_INTO, $u);
while ($res->fetch()) {
// 取得的记录集将放在$u这个对象变量中,在此显示
}
?>

6.存取为关联数据

PDO实现了迭代器(Iteator)接口,允许一个方法实现迭代的功能。

$res = $db->query(
“SELECT * FROM users”,
PDO::FETCH_ASSOC
);
foreach ($res as $row) {
// $row是一个关联数组,可以直接显示,如$row['id']
}
?>

7.fetchAll()方法

PDO也提供了和ADODB类似的fetchAll()方法,它允许从一个结果集中取得数据,然后放于关联数组中。

$db->setAttribute(PDO::ATTR_CASE, PDO::CASE_UPPER);
$qry = “SELECT * FROM users”;
$res = $db->query($qry)->fetchAll(PDO::FETCH_ASSOC);
?>
或者获取到索引数组里:
$res = $db->query("SELECT * FROM foo");
$result_arr = $res->fetchAll();
print_r($result_arr);
?>

数字索引数组比较浪费资源,请尽量使用关联数组,这样可以在内存中使用相当密集的大型结果集。

相关说明如下:

setAttribute()方法用于设置部分属性,主要属性有:PDO::ATTR_CASE、PDO::ATTR_ERRMODE等,这里需要设置的是PDO::ATTR_CASE,就是使用关联索引获取数据集时,关联索引是大写还是小写,有如下几个选择:

PDO::CASE_LOWER——强制列名是小写;

PDO::CASE_NATURAL——列名按照原始的方式;

PDO::CASE_UPPER——强制列名为大写。

我们使用setFetchMode方法来设置获取结果集的返回值的数据类型,类型有:

PDO::FETCH_ASSOC——关联数组形式;

PDO::FETCH_NUM——数字索引数组形式;

PDO::FETCH_BOTH——两种数组形式都有,这是默认的;

PDO::FETCH_OBJ——按照对象的形式,类似于以前的 mysql_fetch_object()。

当然,一般情况下,我们使用PDO::FETCH_ASSOC取得关联数组。具体使用哪种类型,应按照自己的实际应用选择。

8.fetchColumn()方法

如果想获取指定记录里的一个字段结果,则可以使用PDOStatement::fetchColumn()。

$rs = $db->query("SELECT COUNT(*) FROM foo");
$col = $rs->fetchColumn();
echo $col;
?>


一般使用fetchColumn()方法进行count统计,对某些只需要单字段的记录可以很好地操作。

9.回调函数

PDO还规定在每一个fetch模式下,经过处理后的结果中使用一个回调函数。

function draw_message($subject,$email) { … }
$res = $db->query(“SELECT * FROM msg”);
$res->fetchAll(PDO::FETCH_FUNC,“draw_message”);
?>

10.直接查询的问题

直接使用Query查询行每次都会直接提交给数据库,如果查询较多,每次频频查询将导致效率降低。
另外,在安全问题上,没有过滤一些特殊字符容易产生SQL注入。

11.过滤字符

下面我们来看看如何使用PDO进行过滤引起SQL注入的方法,即过滤特殊字符。我们在PDO中使用quote()方法,使用例子如下:

$query = “SELECT * FROM users WHERE
login=“.$db->quote($_POST[‘login’]).”
AND
passwd=“.$db->quote($_POST[‘pass’]);

12.事务处理

PDO驱动程序支持所有的事务数据库,并且PDO提供更简便的方法,如下:

$db->beginTransaction();
if ($db->exec($qry) === FALSE) {
$db->rollback();
}
$db->commit();
?>

13.执行一个批处理事务

在下面的示例中,假设我们为一个新雇员创建一组条目,这个雇员有一个ID号,即23。除了输入这个雇员的基本数据外,还需要记录雇员的薪水。分别完成两个更新很简单,但通过将这两个更新包括在beginTransaction()和commit()调用中,就可以保证在更改完成之前,其他人无法看到更改。如果发生了错误,catch块可以回滚事务开始以来发生的所有更改,并打印出一条错误消息。代码内容如下:

try {
$dbh = new PDO('odbc:SAMPLE', 'db2inst1', 'ibmdb2', 
array(PDO_ATTR_PERSISTENT => true));
echo "Connected\n";
$dbh->setAttribute(PDO_ATTR_ERRMODE, PDO_ERRMODE_EXCEPTION);
$dbh->beginTransaction();
$dbh->exec("insert into staff (id, first, last)
values (23, 'Joe', 'Bloggs')");
$dbh->exec("insert into salarychange (id, amount, changedate) 
values (23, 50000, NOW())");
$dbh->commit();

} catch (Exception $e) {
$dbh->rollBack();
echo "Failed: " . $e->getMessage();
}
?>


并不是一定要在事务中做出更新,也可以通过复杂的查询来提取数据,还可以使用信息构建更多的更新和查询。当事务在活动时,可以保证其他人在工作进行当中无法做出更改。事实上,这不是100%的正确,但如果您之前没有听说过事务的话,这样介绍也未尝不可。
下面是一个扩展PDO&PDO语句的类,内容如下:

class Database extends PDO{
function __construct()   {
parent::__construct('mysql:dbname=test;host=
localhost', 'root', '');
$this->setAttribute(PDO::ATTR_STATEMENT_CLASS,
array('DBStatement'array($this)));
}
}

class DBStatement extends PDOStatement{
public $dbh;
protected function __construct($dbh)   {
$this->dbh = $dbh;
$this->setFetchMode(PDO::FETCH_OBJ);
}
public function foundRows()   {
$rows = $this->dbh->prepare('SELECT found_rows()
AS rows',array(PDO::MYSQL_ATTR_ USE_BUFFERED_QUERY =
> TRUE));
$rows->execute();
$rowsCount = $rows->fetch(PDO::FETCH_OBJ)->rows;
$rows->closeCursor();
return $rowsCount;
}
}
?>

14.存储过程

在MySQL一章,我们已经了解了存储过程的创建,下面我们来看使用PDO调用的例子:

$stmt = $dbh->prepare("CALL sp_set_string(?)");
$stmt->bindParam(1, $str);
$str = ‘hospinfo’; //绑定参数
$stmt->execute();
?>

与先前讲过的绑定例子差不多,只是这里使用了“?”数据绑定方法,sp_set_string是存储过程名称。
带有输出参数的存储过程:

$stmt = $dbh->prepare("CALL sp_get_string(?)");
$stmt->bindParam(1, $ret,PDO:ARAM_STR, 4000);
if ($stmt->execute()) {
echo "返回值 $ret\n";
}

下面是绑定列输出的脚本例子:

$stmt = $dbh->prepare("SELECT extension, name from CREDITS");
if ($stmt->execute()) {
$stmt->bindColumn('extension', $extension);
$stmt->bindColumn('name', $name);
while ($stmt->fetch(PDO::FETCH_BOUND)) {
echo "Extension: $extension\n";
echo "Author: $name\n";
}
}
?>

标签: 数组, query, PDO, res

PHP多条件查询

在我们的网站设计过程中,经常会用到多条件查询,本文的源码是一个二手房屋查询的例子。在本例中,我们要实现能够通过地理位置,物业类型,房屋价格,房屋面积及信息发布日期等多个条件查询到客户所需的资料。

查询文件(search.php)

一、生成查询语句:

<?
$conn=mysql_connect("localhost","root","");
$db=mysql_select_db("lingyun");
$query="select * from message where tradetype='".$tradetype."'"; //交易类型,如出租,出售
$SQL=$SQL . "wuye='" . $wuye . "'";
if($housetype!="不限"){
$query.=" && housetype='".$housetype."'"; //房屋类型,如二室一厅,三室二厅
}
if($degree!="不限"){
$query.=" && degree='".$degree."'"; //新旧程度
}
if($wuye!="不限"){
$query.=" && wuye='".$wuye."'";   //物业类型 如住房,商铺
}
if($price2!=""){
switch($price1){
case "大于":
$query.=" && price>'".$price2."'";   //价格
break;
case "等于":
$query.=" && price='".$price2."'";
break;
case "小于":
$query.=" && price<'".$price2."'";
break;
}
}
if($area2!=""){
switch($area1){
case "大于":
$query.=" && area>'".$area2."'"; //面积
break;
case "等于":
$query.=" && area='".$area2."'";
break;
case "小于":
$query.=" && area<'".$area2."'";
break;
}
}
switch($pubdate){                   //发布日期
case "本星期内":
$query.=" && TO_DAYS(NOW()) - TO_DAYS(date)<=7";
break;
case "一个月内":
$query.=" && TO_DAYS(NOW()) - TO_DAYS(date)<=30";
break;
case "三个月内":
$query.=" && TO_DAYS(NOW()) - TO_DAYS(date)<=91";
break;
case "六个月内":
$query.=" && TO_DAYS(NOW()) - TO_DAYS(date)<=183";
break;
}
if($address!=""){
$query.=" && address like '%$address%'"; //地址
}
if(!$page){
$page=1;
}
?>

二、输出查询结果:

<?php
     if ($page){
     $page_size=20;
     $result=mysql_query($query);
     #$message_count=mysql_result($result,0,"total");
     $message_count=10;
     $page_count=ceil($message_count/$page_size);
     $offset=($page-1)*$page_size;
     $query=$query." order by date desc limit $offset, $page_size";
     $result=mysql_query($query);
     if($result){
     $rows=mysql_num_rows($result);
     if($rows!=0){
     while($myrow=mysql_fetch_array($result)){
     echo "<tr>";
     echo "<td width='15' height='12'><img src='image/home2.gif' width='14' height='14'></td>";
     echo "<td width='540' height='12'>$myrow[id]&nbsp;$myrow[tradetype]&nbsp;$myrow[address]&nbsp;$myrow[wuye]($myrow[housetype])<font style='font-size:9pt'>[$myrow[date]]</font>";
     echo "</td>";
     echo "<td width='75' height='12'><a href='view_d.php?code=$myrow[code]' target='_blank'>详细内容</a></td>";
     echo "</tr>";
         }
       }
     else echo "<tr><td><div align='center'><img src='image/sorry.gif'><br><br>没有找到满足你条件的记录</div></td></tr>";
     }
         $prev_page=$page-1;
         $next_page=$page+1;
         echo "<div align='center'>";
         echo "&nbsp;第".$page."/".$page_count."页&nbsp";
         if ($page<=1){
             echo "|第一页|";
            }
         else{
             echo "<a href='$PATH_INFO?page=1'>|第一页|</a>";
             }
         echo " ";
         if ($prev_page<1){
             echo "|上一页|";
            }
         else{
             echo "<a href='$PATH_INFO?page=$prev_page'>|上一页|</a>";
             }
         echo " ";
         if ($next_page>$page_count){
             echo "|下一页|";
             }
         else{
             echo "<a href='$PATH_INFO?page=$next_page'>|下一页|</a>";
              }
         echo " ";
         if ($page>=$page_count){
             echo "|最后一页|";
               }
         else{
             echo "<a href='$PATH_INFO?page=$page_count'>|最后一页|</a>";
             }
        echo "</div>";
    }
     else{
         echo "<p align='center'>现在还没有房屋租赁信息!</p>";
       }
   echo "<hr width="100%" size="1">";
?>
    </table>

标签: php, query, echo

三种方法连接及操作MYSQL数据库

1、使用Mysqli操作Mysql                //注:mysqli 扩展允许用户访问由MySQL 4.1或更高版本所提供的功能。
$connect = mysqli_connect("host","username","passwd","db",port);
/**
* 以上是与MYSQL建立连接。
* host:为MYSQL主机地址类型为字符型。
* username:为MYSQL登录用户名类型为字符型。
* passwd:为MYSQL登录密码类型为字符型。
* db:为MYSQL数据库名称类型为字符型。
* port:为MYSQL数据库的端口号。
*/

$sSQL = "select * from db";
/*需要执行的SQL语句*/
$query = mysqli_query($connect,$sSQL);
/*
$connect:link为链接源
$sSQL:query为请求也指的是需执行的SQL语句
*/

while($arr = mysqli_fetch_array($query)){
/*$query:循环$query所执行的结果*/
print_r($arr);
/*输入相应该的字段值*/
}
mysqli_free_result($query);
/*释放结果集*/
mysqli_close($connect);
/*关闭数据库连接*/

2、使用Mysql操作Mysql
mysql_connect("host","username","passwd",port);
/**
* 以上是与MYSQL建立连接。
* host:为MYSQL主机地址类型为字符型。
* username:为MYSQL登录用户名类型为字符型。
* passwd:为MYSQL登录密码类型为字符型。
* port:为MYSQL数据库的端口号。
*/

mysql_select_db("db");
/*
选择数据库
db为数据库名
*/
$sSQL = "select * from db";
/*SQL查询语句*/
$query = mysql_query($sSQL);
/*
$sSQL:query为请求也指的是需执行的SQL语句
*/

while($arr = mysql_fetch_array($query)){
/*$query:循环$query所执行的结果*/
/*输入相应该的字段值*/
print_r($arr);
}
mysql_free_result($query);
/*释放结果集*/
mysql_close();
/*关闭数据库连接*/


3、以OOP方式使用mysqli

   $conn = new mysqli("host","username","passwd","db",port);
/**
* 以上是与MYSQL建立连接。
* host:为MYSQL主机地址类型为字符型。
* username:为MYSQL登录用户名类型为字符型。
* passwd:为MYSQL登录密码类型为字符型。
* db:为MYSQL数据库名称类型为字符型。
* port:为MYSQL数据库的端口号。
*/

   $sSQL = "select * from user";
/*SQL查询语句*/
   $query = $conn->query($sSQL);
/*
$sSQL:query为请求也指的是需执行的SQL语句
*/

   while($arr = $query->fetch_array()){
/*$query:循环$query所执行的结果*/
    print_r($arr);
   }
   $query->close();
/*释放结果集*/
   $conn->close();
/*关闭数据库连接*/

php中的事务处理 mysqli

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

<?php
$db = new mysqli("localhost","root","","test"); //连接数据库

$db->autocommit(false); //设置为非自动提交——事务处理

$sql1  = "INSERT INTO `test`.`test1` (`name` )VALUES ('1' )";

$result1 = $db->query($sql1);

$sql2  = "INSERT INTO `test`.`test2` (`a` )VALUES ('1')";

$result2 = $db->query($sql2);

if ($result1 && $result2) {

$db->commit();  //全部成功,提交执行结果

echo '提交';

} else {

$db->rollback(); //有任何错误发生,回滚并取消执行结果

echo '回滚';

}

$db->autocommit(true); //设置为非自动提交——事务处理

$db->close();

?>