php mysql備份恢復分卷處理

2024-05-04 21:49:12

字體：大中小

來源：轉載

供稿：網友

分卷處理就是把握們要處理的數據分成一個個小文件進行處理了,下面我來給大家介紹一個php mysql備份恢復分卷處理類,實現mysql數據庫分卷備份,選擇表進行備份,實現單個sql文件及分卷sql導入.

分卷導入類及思路詳解

數據庫導入導出是一個后臺必要擁有的功能,網上一搜,有很多關于數據庫導入導出的,但基本上一個大的系統,包含了許多我們并不需要的,而且他們都是自己的后臺的形式,我并不喜歡的是拿人家的東西整合到自己的后臺,我需要的是自己東西,于是參照了很多,自己寫了一個關于分卷導入類,以方便調用,歡迎大家拍磚.

這里針對分卷文件是以‘_v1.sql’為結尾,實現單個sql文件及分卷sql導入,分卷導入可選擇是否當前分卷導入余下分卷,我們只需要直接調用類即可完成.

分別是主機，用戶名，密碼，數據庫名，數據庫編碼

$db = new DataManage ( 'localhost', 'root', 'root', 'test', 'utf8' );

sql文件,是否只導入單個sql(即如果有其他分卷也不導入).

$db->restore ( './backup/20120516211738_all_v1.sql', false );對應如何去列出備份的sql文件或選擇sql之類的,自己去實現,那個不在這個范疇了,也很簡單的.

還有目前只實現了數據庫導入,關于數據庫導出的,正在編寫功能,下面是完整的類代碼,具體思路及實現代碼里面都有說明,這里不在贅述,代碼如下:

<?php

/**

* @author yanue

* @copyright Copyright (c) 2012 m.survivalescaperooms.com

* 說明：分卷文件是以_v1.sql為結尾

* 功能：實現單個sql文件及分卷sql導入,分卷導入可選擇是否當前分卷導入余下分卷

* 使用方法：

*

*

* ------------------------------------------------------------------

//分別是主機，用戶名，密碼，數據庫名，數據庫編碼

$db = new DataManage ( 'localhost', 'root', 'root', 'test', 'utf8' );

//sql文件，是否只導入單個sql（即如果有其他分卷也不導入）

$db->restore ( './backup/20120516211738_all_v1.sql', false );

*----------------------------------------------------------------------

*/

class DataManage {

var $db; // 數據庫連接

var $database; // 所用數據庫

var $sqldir; // 數據庫備份文件夾

/**

 * 初始化

 *

 * @param string $host

 * @param string $username

 * @param string $password

 * @param string $database

 * @param string $charset

 */

function __construct($host = 'localhost', $username = 'root', $password = '', $database = 'test', $charset = 'utf8') {

 $this->host = $host;

 $this->username = $username;

 $this->password = $password;

 $this->database = $database;

 $this->charset = $charset;

 // 連接數據庫

 $this->db = mysql_connect ( $this->host, $this->username, $this->password ) or die ( "數據庫連接失敗." );

 // 選擇使用哪個數據庫

 mysql_select_db ( $this->database, $this->db ) or die ( "無法打開數據庫" );

 // 數據庫編碼方式

 mysql_query ( 'SET NAMES ' . $this->charset, $this->db );

}

/**

 * 導入備份數據

 * 說明：分卷文件格式20120516211738_all_v1.sql

 *

 * @param string $sqlfile

 * @param bool $single

 */

function restore($sqlfile, $single = FALSE) {

 // 檢測文件是否存在

 if (! file_exists ( $sqlfile )) {

 exit ( "文件不存在！請檢查" );

 }

 $this->lock ( $this->database );

 // 獲取數據庫存儲位置

 $sqlpath = pathinfo ( $sqlfile );

 $this->sqldir = $sqlpath ['dirname'];

 // 檢測是否包含分卷，將類似20120516211738_all_v1.sql從_v分開,有則說明有分卷

 $volume = explode ( "_v", $sqlfile );

 $volume_path = $volume [0];

 echo "請勿刷新及關閉瀏覽器以防止程序被中止，如有不慎！將導致數據庫結構受損 ";

 echo "正在導入備份數據，請稍等！ ";

 if (emptyempty ( $volume [1] ) || $single) {

 echo "正在導入sql：" . $sqlfile . ' ';

 // 沒有分卷

 if ($this->_import ( $sqlfile )) {

 echo "數據庫導入成功！";

 } else {

 exit ( '數據庫導入失敗！' );

 }

 } else {

 // 存在分卷，則獲取當前是第幾分卷，循環執行余下分卷

 $volume_id = explode ( ".sq", $volume [1] );

 // 當前分卷為$volume_id

 $volume_id = intval ( $volume_id [0] );

 while ( $volume_id ) {

 $tmpfile = $volume_path . "_v" . $volume_id . ".sql";

 // 存在其他分卷，繼續執行

 if (file_exists ( $tmpfile )) {

 // 執行導入方法

 echo "正在導入分卷$volume_id：" . $tmpfile . ' ';

 if ($this->_import ( $tmpfile )) {

 } else {

 exit ( "導入分卷$volume_id：" . $tmpfile . '失??！可能是數據庫結構已損壞！請嘗試從分卷1開始導入' );

 }

 } else {

 echo "此分卷備份全部導入成功！ ";

 return;

 }

 $volume_id ++;

 }

 }

}

/**

 * 將sql導入到數據庫（普通導入）

 *

 * @param string $sqlfile

 * @return boolean

 */

private function _import($sqlfile) {

 $name = basename ( $sqlfile );

 $sqls = file ( $sqlfile );

 foreach ( $sqls as $sql ) {

 str_replace ( "r", "", $sql );

 str_replace ( "n", "", $sql );

 if (! mysql_query ( trim ( $sql ), $this->db ))

 return false;

 }

 return true;

}

// 關閉數據庫連接

private function close() {

 mysql_close ( $this->db );

}

// 鎖定數據庫，以免備份或導入時出錯

private function lock($tablename, $op = "WRITE") {

 if (mysql_query ( "lock tables " . $tablename . " " . $op ))

 return true;

 else

 return false;

}

// 解鎖

private function unlock() {

 if (mysql_query ( "unlock tables" ))

 return true;

 else

 return false;

}

// 析構

function __destruct() {

 mysql_query ( "unlock tables", $this->db );

 mysql_close ( $this->db );

}

}

?>

mysql備份恢復分卷處理,調用簡單.

分卷導入思路:按行讀取sql文件,將每一行當作完整的sql語句存到數組再循環執行插入數據庫就可以了,但是在創建表語句分了多行,這個需要單獨處理,就這個花了我好長時間的.感覺文章好長啊,主要是那個類文件給占用了.

更新說明:

1.去除sql導入的時候排除sql文件里面的注釋’– ‘ 從而解決sql中單雙引號不能導入

2.單行讀取后的sql直接執行,避免重新將sql語句組合到數組中再從數組中讀取導入sql,提高效率.

下載地址: https://github.com/yanue/Dbmanage

導出后的sql文件格式如下:

--

-- MySQL database dump

-- Created by DBManage class, Power By yanue.

--

-- 主機: localhost

-- 生成日期: 2012 年 10 月 06 日 22:32

-- MySQL版本: 5.1.50-community

-- PHP 版本: 5.3.9-ZS5.6.0

--

-- 數據庫: `test`

--

-- -------------------------------------------------------

--

-- 表的結構aa

--

DROP TABLE IF EXISTS `aa`;

CREATE TABLE `aa` (

 `id` int(10) unsigned NOT NULL AUTO_INCREMENT,

 `content` text NOT NULL,

 PRIMARY KEY (`id`)

) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

--

-- 轉存表中的數據 aa

--

INSERT INTO `aa` VALUES('1','我是測試數據呵呵');

下面是類代碼:

<?php

/**

* @author yanue

* @copyright Copyright (c) 2012 yanue.net

* @link http://Vevb.com

* @version 1.1

* 創建時間： 2012年5月21日

更新時間： 2012年10月6日

更新說明： 1.去除sql導入的時候排除sql文件里面的注釋'-- ' 從而解決sql中單雙引號不能導入

2.單行讀取后的sql直接執行，避免重新將sql語句組合到數組中再從數組中讀取導入sql，提高效率

* 說明：分卷文件是以_v1.sql為結尾(20120522021241_all_v1.sql)

* 功能：實現mysql數據庫分卷備份,選擇表進行備份,實現單個sql文件及分卷sql導入

* 使用方法：

*

* ------1. 數據庫備份（導出）------------------------------------------------------------

//分別是主機，用戶名，密碼，數據庫名，數據庫編碼

$db = new DBManage ( 'localhost', 'root', 'root', 'test', 'utf8' );

// 參數：備份哪個表(可選),備份目錄(可選，默認為backup),分卷大小(可選,默認2000，即2M)

$db->backup ();

* ------2. 數據庫恢復（導入）------------------------------------------------------------

//分別是主機，用戶名，密碼，數據庫名，數據庫編碼

$db = new DBManage ( 'localhost', 'root', 'root', 'test', 'utf8' );

//參數：sql文件

$db->restore ( './backup/20120516211738_all_v1.sql');

*----------------------------------------------------------------------

*/

class DbManage {

 var $db; // 數據庫連接

 var $database; // 所用數據庫

 var $sqldir; // 數據庫備份文件夾

 // 換行符

 private $ds = "n";

 // 存儲SQL的變量

 public $sqlContent = "";

 // 每條sql語句的結尾符

 public $sqlEnd = ";";

 /**

 * 初始化

 *

 * @param string $host

 * @param string $username

 * @param string $password

 * @param string $database

 * @param string $charset

 */

 function __construct($host = 'localhost', $username = 'root', $password = '', $database = 'test', $charset = 'utf8') {

 $this->host = $host;

 $this->username = $username;

 $this->password = $password;

 $this->database = $database;

 $this->charset = $charset;

 set_time_limit(0);//無時間限制

@ob_end_flush();

 // 連接數據庫

 $this->db = @mysql_connect ( $this->host, $this->username, $this->password ) or die( 'Mysql Connect Error : '.mysql_error().'');

 // 選擇使用哪個數據庫

 mysql_select_db ( $this->database, $this->db ) or die('Mysql Connect Error:'.mysql_error().'');

 // 數據庫編碼方式

 mysql_query ( 'SET NAMES ' . $this->charset, $this->db );

 }

 /*

 * 新增查詢數據庫表

 */

 function getTables() {

 $res = mysql_query ( "SHOW TABLES" );

 $tables = array ();

 while ( $row = mysql_fetch_array ( $res ) ) {

 $tables [] = $row [0];

 }

 return $tables;

 }

 /*

 *

 * ------------------------------------------數據庫備份start----------------------------------------------------------

 */

 /**

 * 數據庫備份

 * 參數：備份哪個表(可選),備份目錄(可選，默認為backup),分卷大小(可選,默認2000，即2M)

 *

 * @param $string $dir

 * @param int $size

 * @param $string $tablename

 */

 function backup($tablename = '', $dir, $size) {

 $dir = $dir ? $dir : './backup/';

 // 創建目錄

 if (! is_dir ( $dir )) {

 mkdir ( $dir, 0777, true ) or die ( '創建文件夾失敗' );

 }

 $size = $size ? $size : 2048;

 $sql = '';

 // 只備份某個表

 if (! emptyempty ( $tablename )) {

 if(@mysql_num_rows(mysql_query("SHOW TABLES LIKE '".$tablename."'")) == 1) {

 } else {

 $this->_showMsg('表-' . $tablename .'-不存在，請檢查！',true);

 die();

 }

 $this->_showMsg('正在備份表 ' . $tablename.'');

 // 插入dump信息

 $sql = $this->_retrieve ();

 // 插入表結構信息

 $sql .= $this->_insert_table_structure ( $tablename );

 // 插入數據

 $data = mysql_query ( "select * from " . $tablename );

 // 文件名前面部分

 $filename = date ( 'YmdHis' ) . "_" . $tablename;

 // 字段數量

 $num_fields = mysql_num_fields ( $data );

 // 第幾分卷

 $p = 1;

 // 循環每條記錄

 while ( $record = mysql_fetch_array ( $data ) ) {

 // 單條記錄

 $sql .= $this->_insert_record ( $tablename, $num_fields, $record );

 // 如果大于分卷大小，則寫入文件

 if (strlen ( $sql ) >= $size * 1024) {

 $file = $filename . "_v" . $p . ".sql";

 if ($this->_write_file ( $sql, $file, $dir )) {

 $this->_showMsg("表-" . $tablename . "-卷-" . $p . "-數據備份完成,備份文件 [ " .$dir . $file ." ]");

 } else {

 $this->_showMsg("備份表 -" . $tablename . "- 失敗",true);

 return false;

 }

 // 下一個分卷

 $p ++;

 // 重置$sql變量為空，重新計算該變量大小

 $sql = "";

 }

 }

 // 及時清除數據

 unset($data,$record);

 // sql大小不夠分卷大小

 if ($sql != "") {

 $filename .= "_v" . $p . ".sql";

 if ($this->_write_file ( $sql, $filename, $dir )) {

 $this->_showMsg( "表-" . $tablename . "-卷-" . $p . "-數據備份完成,備份文件 [ " .$dir . $filename ." ]");

 } else {

 $this->_showMsg("備份卷-" . $p . "-失敗 ");

 return false;

 }

 }

 $this->_showMsg("恭喜您! 備份成功");

 } else {

 $this->_showMsg('正在備份');

 // 備份全部表

 if ($tables = mysql_query ( "show table status from " . $this->database )) {

 $this->_showMsg("讀取數據庫結構成功！");

 } else {

 $this->_showMsg("讀取數據庫結構失?。?quot;);

 exit ( 0 );

 }

 // 插入dump信息

 $sql .= $this->_retrieve ();

 // 文件名前面部分

 $filename = date ( 'YmdHis' ) . "_all";

 // 查出所有表

 $tables = mysql_query ( 'SHOW TABLES' );

 // 第幾分卷

 $p = 1;

 // 循環所有表

 while ( $table = mysql_fetch_array ( $tables ) ) {

 // 獲取表名

 $tablename = $table [0];

 // 獲取表結構

 $sql .= $this->_insert_table_structure ( $tablename );

 $data = mysql_query ( "select * from " . $tablename );

 $num_fields = mysql_num_fields ( $data );

 // 循環每條記錄

 while ( $record = mysql_fetch_array ( $data ) ) {

 // 單條記錄

 $sql .= $this->_insert_record ( $tablename, $num_fields, $record );

 // 如果大于分卷大小，則寫入文件

 if (strlen ( $sql ) >= $size * 1000) {

 $file = $filename . "_v" . $p . ".sql";

 // 寫入文件

 if ($this->_write_file ( $sql, $file, $dir )) {

 $this->_showMsg("-卷-" . $p . "-數據備份完成,備份文件 [ ".$dir.$file." ]");

 } else {

 $this->_showMsg("卷-" . $p . "-備份失敗!",true);

 return false;

 }

 // 下一個分卷

 $p ++;

 // 重置$sql變量為空，重新計算該變量大小

 $sql = "";

 }

 }

 }

 // sql大小不夠分卷大小

 if ($sql != "") {

 $filename .= "_v" . $p . ".sql";

 if ($this->_write_file ( $sql, $filename, $dir )) {

 $this->_showMsg("-卷-" . $p . "-數據備份完成,備份文件 [ ".$dir.$filename." ]");

 } else {

 $this->_showMsg("卷-" . $p . "-備份失敗",true);

 return false;

 }

 }

 $this->_showMsg("恭喜您! 備份成功");

 }

 }

 // 及時輸出信息

 private function _showMsg($msg,$err=false){

 $err = $err ? "ERROR:" : '' ;

 echo "".$err . $msg."";

 flush();

 }

 /**

 * 插入數據庫備份基礎信息

 *

 * @return string

 */

 private function _retrieve() {

 $value = '';

 $value .= '--' . $this->ds;

 $value .= '-- MySQL database dump' . $this->ds;

 $value .= '-- Created by DbManage class, Power By yanue. ' . $this->ds;

 $value .= '-- http://yanue.net ' . $this->ds;

 $value .= '--' . $this->ds;

 $value .= '-- 主機: ' . $this->host . $this->ds;

 $value .= '-- 生成日期: ' . date ( 'Y' ) . ' 年 ' . date ( 'm' ) . ' 月 ' . date ( 'd' ) . ' 日 ' . date ( 'H:i' ) . $this->ds;

 $value .= '-- MySQL版本: ' . mysql_get_server_info () . $this->ds;

 $value .= '-- PHP 版本: ' . phpversion () . $this->ds;

 $value .= $this->ds;

 $value .= '--' . $this->ds;

 $value .= '-- 數據庫: `' . $this->database . '`' . $this->ds;

 $value .= '--' . $this->ds . $this->ds;

 $value .= '-- -------------------------------------------------------';

 $value .= $this->ds . $this->ds;

 return $value;

 }

 /**

 * 插入表結構

 *

 * @param unknown_type $table

 * @return string

 */

 private function _insert_table_structure($table) {

 $sql = '';

 $sql .= "--" . $this->ds;

 $sql .= "-- 表的結構" . $table . $this->ds;

 $sql .= "--" . $this->ds . $this->ds;

 // 如果存在則刪除表

 $sql .= "DROP TABLE IF EXISTS `" . $table . '`' . $this->sqlEnd . $this->ds;

 // 獲取詳細表信息

 $res = mysql_query ( 'SHOW CREATE TABLE `' . $table . '`' );

 $row = mysql_fetch_array ( $res );

 $sql .= $row [1];

 $sql .= $this->sqlEnd . $this->ds;

 // 加上

 $sql .= $this->ds;

 $sql .= "--" . $this->ds;

 $sql .= "-- 轉存表中的數據 " . $table . $this->ds;

 $sql .= "--" . $this->ds;

 $sql .= $this->ds;

 return $sql;

 }

 /**

 * 插入單條記錄

 *

 * @param string $table

 * @param int $num_fields

 * @param array $record

 * @return string

 */

 private function _insert_record($table, $num_fields, $record) {

 // sql字段逗號分割

 $insert = '';

 $comma = "";

 $insert .= "INSERT INTO `" . $table . "` VALUES(";

 // 循環每個子段下面的內容

 for($i = 0; $i < $num_fields; $i ++) {

 $insert .= ($comma . "'" . mysql_escape_string ( $record [$i] ) . "'");

 $comma = ",";

 }

 $insert .= ");" . $this->ds;

 return $insert;

 }

 /**

 * 寫入文件

 *

 * @param string $sql

 * @param string $filename

 * @param string $dir

 * @return boolean

 */

 private function _write_file($sql, $filename, $dir) {

 $dir = $dir ? $dir : './backup/';

 // 創建目錄

 if (! is_dir ( $dir )) {

 mkdir ( $dir, 0777, true );

 }

 $re = true;

 if (! @$fp = fopen ( $dir . $filename, "w+" )) {

 $re = false;

 $this->_showMsg("打開sql文件失敗！",true);

 }

 if (! @fwrite ( $fp, $sql )) {

 $re = false;

 $this->_showMsg("寫入sql文件失敗，請文件是否可寫",true);

 }

 if (! @fclose ( $fp )) {

 $re = false;

 $this->_showMsg("關閉sql文件失??！",true);

 }

 return $re;

 }

 /*

 *

 * -------------------------------上：數據庫導出-----------分割線----------下：數據庫導入--------------------------------

 */

 /**

 * 導入備份數據

 * 說明：分卷文件格式20120516211738_all_v1.sql

 * 參數：文件路徑(必填)

 *

 * @param string $sqlfile

 */

 function restore($sqlfile) {

 // 檢測文件是否存在

 if (! file_exists ( $sqlfile )) {

 $this->_showMsg("sql文件不存在！請檢查",true);

 exit ();

 }

 $this->lock ( $this->database );

 // 獲取數據庫存儲位置

 $sqlpath = pathinfo ( $sqlfile );

 $this->sqldir = $sqlpath ['dirname'];

 // 檢測是否包含分卷，將類似20120516211738_all_v1.sql從_v分開,有則說明有分卷

 $volume = explode ( "_v", $sqlfile );

 $volume_path = $volume [0];

 $this->_showMsg("請勿刷新及關閉瀏覽器以防止程序被中止，如有不慎！將導致數據庫結構受損");

 $this->_showMsg("正在導入備份數據，請稍等！");

 if (emptyempty ( $volume [1] )) {

 $this->_showMsg ( "正在導入sql：" . $sqlfile . '');

 // 沒有分卷

 if ($this->_import ( $sqlfile )) {

 $this->_showMsg( "數據庫導入成功！");

 } else {

 $this->_showMsg('數據庫導入失??！',true);

 exit ();

 }

 } else {

 // 存在分卷，則獲取當前是第幾分卷，循環執行余下分卷

 $volume_id = explode ( ".sq", $volume [1] );

 // 當前分卷為$volume_id

 $volume_id = intval ( $volume_id [0] );

 while ( $volume_id ) {

 $tmpfile = $volume_path . "_v" . $volume_id . ".sql";

 // 存在其他分卷，繼續執行

 if (file_exists ( $tmpfile )) {

 // 執行導入方法

 $this->msg .= "正在導入分卷 $volume_id ：" . $tmpfile . ' ';

 if ($this->_import ( $tmpfile )) {

 } else {

 $volume_id = $volume_id ? $volume_id :1;

 exit ( "導入分卷：" . $tmpfile . '失敗！可能是數據庫結構已損壞！請嘗試從分卷1開始導入' );

 }

 } else {

 $this->msg .= "此分卷備份全部導入成功！ ";

 return;

 }

 $volume_id ++;

 }

 }if (emptyempty ( $volume [1] )) {

 $this->_showMsg ( "正在導入sql：" . $sqlfile . '');

 // 沒有分卷

 if ($this->_import ( $sqlfile )) {

 $this->_showMsg( "數據庫導入成功！");

 } else {

 $this->_showMsg('數據庫導入失敗！',true);

 exit ();

 }

 } else {

 // 存在分卷，則獲取當前是第幾分卷，循環執行余下分卷

 $volume_id = explode ( ".sq", $volume [1] );

 // 當前分卷為$volume_id

 $volume_id = intval ( $volume_id [0] );

 while ( $volume_id ) {

 $tmpfile = $volume_path . "_v" . $volume_id . ".sql";

 // 存在其他分卷，繼續執行

 if (file_exists ( $tmpfile )) {

 // 執行導入方法

 $this->msg .= "正在導入分卷 $volume_id ：" . $tmpfile . ' ';

 if ($this->_import ( $tmpfile )) {

 } else {

 $volume_id = $volume_id ? $volume_id :1;

 exit ( "導入分卷：" . $tmpfile . '失?。】赡苁菙祿旖Y構已損壞！請嘗試從分卷1開始導入' );

 }

 } else {

 $this->msg .= "此分卷備份全部導入成功！ ";

 return;

 }

 $volume_id ++;

 }

 }

 }

 /**

 * 將sql導入到數據庫（普通導入）

 *

 * @param string $sqlfile

 * @return boolean

 */

 private function _import($sqlfile) {

 // sql文件包含的sql語句數組

 $sqls = array ();

 $f = fopen ( $sqlfile, "rb" );

 // 創建表緩沖變量

 $create_table = '';

 while ( ! feof ( $f ) ) {

 // 讀取每一行sql

 $line = fgets ( $f );

 // 這一步為了將創建表合成完整的sql語句

 // 如果結尾沒有包含';'(即為一個完整的sql語句，這里是插入語句)，并且不包含'ENGINE='(即創建表的最后一句)

 if (! preg_match ( '/;/', $line ) || preg_match ( '/ENGINE=/', $line )) {

 // 將本次sql語句與創建表sql連接存起來

 $create_table .= $line;

 // 如果包含了創建表的最后一句

 if (preg_match ( '/ENGINE=/', $create_table)) {

 //執行sql語句創建表

 $this->_insert_into($create_table);

 // 清空當前，準備下一個表的創建

 $create_table = '';

 }

 // 跳過本次

 continue;

 }

 //執行sql語句

 $this->_insert_into($line);

 }

 fclose ( $f );

 return true;

 }

 //插入單條sql語句

 private function _insert_into($sql){

 if (! mysql_query ( trim ( $sql ) )) {

 $this->msg .= mysql_error ();

 return false;

 }

 }

 /*

 * -------------------------------數據庫導入end---------------------------------

 */

 // 關閉數據庫連接

 private function close() {

 mysql_close ( $this->db );

 }

 // 鎖定數據庫，以免備份或導入時出錯

 private function lock($tablename, $op = "WRITE") {

 if (mysql_query ( "lock tables " . $tablename . " " . $op ))

 return true;

 else

 return false;

 }

 // 解鎖

 private function unlock() {

 if (mysql_query ( "unlock tables" ))

 return true;

 else

 return false;

 }

 // 析構

 function __destruct() {

 if($this->db){

 mysql_query ( "unlock tables", $this->db );

 mysql_close ( $this->db );

 }

 }

}

?>