[数据库] 增强phplib里的mysql类，事务处理（MYSQL5）

chujian

在原类里加入
  /* 添加sql描述  */

  function Add_SQL($Query_String)
        {
          $this->tCount++;
          $this->aSql[$this->tCount] = $Query_String;
        }

  /* 执行一个SQL语句 有错误返回0，没错误返回1 */
  function db_ExecuteSQL($Query_String)
        {
          if( $Query_String == "")
                {
                  return 0;
                }

          if (!$this->connect()) {
                        return 0; /* we already complained in connect() about that. */
                };

          if ($this->Query_ID) {
                  $this->free();
                }

         $this->Query_ID = @mysql_query($Query_String,$this->Link_ID);

          if (!$this->Query_ID) {
                  return 0;
                }else{
                  return 1;
                }

               
        }

  /* 执行一个事务处理 */
  function Execute()
        {
          /* 执行事务处理开始 */
          if ($this->db_ExecuteSQL("START TRANSACTION")) {

                  for ($i=1; $i<=count($this->aSql); $i++) {
                          $res = $this->db_ExecuteSQL($this->aSql[$i]);

                          if (!$res) {
                                        break;
                                }
                  } //end for

                  if ($res){
                                $res = $this->db_ExecuteSQL("COMMIT");
                                return true;
                        }
                        else {
                                $res = $this->db_ExecuteSQL("ROLLBACK");
                                return false;
                        }

          }//end if tran
        }

使用的时候$DB->Add_SQL("sql语句1");
$DB->Add_SQL("sql语句2");
$DB->Add_SQL("sql语句3");
$DB->Add_SQL("sql语句4");

if($DB->Execute())
{
    echo "操作成功！";
}else{
    echo "操作失败，并且回滚";
}

[ 本帖最后由 HonestQiao 于 2005-12-25 09:16 编辑 ]