一江春水向東流

做一個有思想的人,期待與每一位熱愛思考的人交流,您的關(guān)注是對我最大的支持。

BlogJava :: 首頁 :: 新隨筆 :: 聯(lián)系 :: 聚合

:: 管理 ::

44 隨筆 :: 139 文章 :: 81 評論 :: 0 Trackbacks

<

2025年5月

>

日

一

二

三

四

五

六

27

28

29

30

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

1

2

3

4

5

6

7

常用鏈接

留言簿(12)

隨筆分類(23)

隨筆檔案(42)

文章分類(162)

文章檔案(139)

新聞檔案(10)

2006年11月 (10)

相冊

收藏夾(3)

技術(shù)文章(3) (rss)

搜索

閱讀排行榜

評論排行榜

mysql連接類實現(xiàn)

/* ************************************

????mysql連接類實現(xiàn)?-write?by?三千

?************************************* */

? /*

?使用方法(可以執(zhí)行一般mysql命令,insert,?delete?select??update)

?在文件前,需要加載方法

?require("mysql.class.php")

?$db=new?dbMysql;?加載類

?$db->dbServer="localhost";

?$db->dbUser="root";

?$db->dbPwd="";

?$db->dbDatabase="";

?$db->dbConnect();

?query($sql,$database);

?query_first($sql,$database);

?fetch_array($sql,$database);

?count_records($table,$index,$where,$database);)//為得到一個表記錄的數(shù)目，$table為表名，$index為key，$where為條件，$dbbase為數(shù)據(jù)庫，后兩個可以不選

? */

? class ?db_Mysql

?{

??

?? var ? $usepconnect ;

?? var ? $dbSever ;

?? var ? $dbDatabase ;?

?? var ? $dbbase ;

?? var ? $dbUser ;

?? var ? $dbPwd ;

?? var ? $dbLink ;

?? var ? $query_id ; // ?執(zhí)行query命令的指針

?? var ? $num_rows ; // ?返回的條目數(shù)

?? var ? $insert_id ; // ?傳回最后一次使用?INSERT?指令的?ID

?? var ? $affected_rows ; // ?傳回query命令所影響的列數(shù)目

??????????????????//?INSERT、UPDATE?或?DELETE?所影響的列?(row)?數(shù)目。

??????????????????//?delete?如果不帶where，那么則返回0

?? function ?dbconnect( $dbbase , $usepconnect )

??{

??? // global?$usepconnect;

??? if ( $usepconnect == 1 )

???? $this -> dbLink = @ mysql_pconnect ( $this -> dbServer , $this -> dbUser , $this -> dbPwd); // long?connect

??? else

???? $this -> dbLink = @ mysql_connect ( $this -> dbServer , $this -> dbUser , $this -> dbPwd); // short?connect

???//$this->dbhalt($this->dbbase);

??? if ( ! $this -> dbLink)? $this -> dbhalt( " exsiting?error?when?connecting! " );

??? if ( $this -> dbbase == "" )? $this -> dbbase = $this -> dbDatabase;

??? if ( ! @ mysql_select_db ( $this -> dbbase , $this -> dbLink))

???? $this -> dbhalt( " can't?use?this?database,please?check?database! " );

??}? // ?end?func()?connect?database

??//change?database

?? function ?dbchange_db( $dbbase ){

??? $this -> dbconnect( $dbbase );

??

??}

?? function ?dbquery( $sql ){

??? // if($dbbase!="")?$this->dbchange_db($dbbase);

??? $this -> query_id = mysql_query ( $sql );

??? // print($query_id);

??? if ( ! $this -> query_id)? $this -> dbhalt( " wrong?sql?sentence! " . $sql );

??? return ? $this -> query_id;

??}

?? function ?dbquery_first( $sql , $dbbase ){

??? $query_id = dbquery( $sql , $dbbase );

??? $returnarray = mysql_fetch_array ( $query_id );

??? $this -> num_rows = mysql_num_rows ( $query_id );

??? $this -> dbfree_result( $query_id );

??? return ? $returnarray ;

??}

?? function ?dbhalt( $errmsg ){

??? $msg = "

database?is?wrong!

" ;

??? $msg = $errmsg ;

??? echo " $msg " ;

??? die ();

??}

?? function ?dbfetch_array( $sql , $dbbase , $type ){

??? $query_id = $this -> dbquery( $sql , $dbbase );

??? $this -> numrows = mysql_num_rows ( $query_id );

??? for ( $i = 0 ; $i < $this -> numrows; $i ++ ){

???? if ( $type == 0 )

????? $array [ $i ] = mysql_fetch_array ( $query_id );

???? else

????? $array [ $i ] = mysql_fetch_array ( $query_id );

???}

??? $this -> dbfree_result( $query_id );

??? return ? $array ;

??}

?? function ?dbdelete( $sql , $dbdase ){

??? $query_id = $this -> dbquery( $sql , $dbbase );

??? $this -> affected_rows = mysql_affected_rows ( $this -> dbLink);

??? $this -> free_reuslt( $query_id );

??}

?? function ?dbinsert( $sql , $dbbase ){

??? $query_id = $this -> dbquery( $sql , $dbbase );

??? $this -> insert_id = mysql_insert_id ( $this -> dbLink);

??? $this -> affected_rows = mysql_affected_rows ( $this -> dbLink);

??? $this -> free_reuslt( $query_id );

??}

?? function ?dbupdate( $sql , $dbbase ){

??? $query_id = $this -> dbquery( $sql , $dbbase );

??? $this -> insert_id = mysql_insert_id ( $this -> dbLink);

??? $this -> affected_rows = mysql_affected_rows ( $this -> dbLink);

??? $this -> free_reuslt( $query_id );

??}

?? function ?dbcount_records( $table , $index = " id " , $where = "" , $dbbase ){

??? if ( $dbbase != "" ) $this -> dbchangedb( $dbbase );

??? $result = @ mysql_query ( " select?count( " . $index . " )?as?'num'?form " . $table . " where " . $where , $this -> dbLink);

??? if ( ! $result )? $this -> dbhalt( " wrong?sql?sentence " . $sql );

???? $num = @ mysql_result ( $result , 0 , " num " );

??? return ? $num ;

??}

?? function ?dbgetnum( $result ){

??? $num = @ mysql_numrows ( $result );

??? return ? $num ;

??}

?? function ?dbfree_result( $result_id ){

???@ mysql_free_result ( $query_id );

??}

?? function ?dbclose(){

??? mysql_close ( $this -> dbLink);

??}

?}? // ?end?class

? $db = new ?db_Mysql;

? $db -> dbServer = " localhost " ;

? $db -> dbUser = " root " ;

? $db -> dbPwd = "" ;

? $db -> dbbase = " test " ;?

?>

/*************************************
??? mysql連接類實現(xiàn) -write by 三千
?**************************************/
?/*
?使用方法(可以執(zhí)行一般mysql命令,insert, delete select? update)
?在文件前,需要加載方法
?require("mysql.class.php")
?$db=new dbMysql; 加載類
?$db->dbServer="localhost";
?$db->dbUser="root";
?$db->dbPwd="";
?$db->dbDatabase="";
?$db->dbConnect();

?query($sql,$database);
?query_first($sql,$database);
?fetch_array($sql,$database);
?count_records($table,$index,$where,$database);)//為得到一個表記錄的數(shù)目，$table為表名，$index為key，$where為條件，$dbbase為數(shù)據(jù)庫，后兩個可以不選
?*/

?class db_Mysql
?{
?
? var $usepconnect;
? var $dbSever;
? var $dbDatabase;
? var $dbbase;
? var $dbUser;
? var $dbPwd;
? var $dbLink;
? var $query_id;// 執(zhí)行query命令的指針
? var $num_rows;// 返回的條目數(shù)
? var $insert_id;// 傳回最后一次使用 INSERT 指令的 ID
? var $affected_rows;// 傳回query命令所影響的列數(shù)目
????????????????? // INSERT、UPDATE 或 DELETE 所影響的列 (row) 數(shù)目。
????????????????? // delete 如果不帶where，那么則返回0
? function dbconnect($dbbase,$usepconnect)
? {
?? //global $usepconnect;
?? if($usepconnect==1)
??? $this->dbLink=@mysql_pconnect($this->dbServer,$this->dbUser,$this->dbPwd);//long connect
?? else
??? $this->dbLink=@mysql_connect($this->dbServer,$this->dbUser,$this->dbPwd);//short connect
?? //$this->dbhalt($this->dbbase);
?? if(!$this->dbLink) $this->dbhalt("exsiting error when connecting!");
?? if($this->dbbase=="") $this->dbbase=$this->dbDatabase;
?? if(!@mysql_select_db($this->dbbase,$this->dbLink))
??? $this->dbhalt("can't use this database,please check database!");
? } // end func() connect database
? //change database
? function dbchange_db($dbbase){
?? $this->dbconnect($dbbase);
?
? }
? function dbquery($sql){
?? //if($dbbase!="") $this->dbchange_db($dbbase);
?? $this->query_id=mysql_query($sql);
?? //print($query_id);
?? if(!$this->query_id) $this->dbhalt("wrong sql sentence!".$sql);
?? return $this->query_id;
? }
? function dbquery_first($sql,$dbbase){
?? $query_id=dbquery($sql,$dbbase);
?? $returnarray=mysql_fetch_array($query_id);
?? $this->num_rows=mysql_num_rows($query_id);
?? $this->dbfree_result($query_id);
?? return $returnarray;
? }
? function dbhalt($errmsg){
?? $msg="

database is wrong!

";
?? $msg=$errmsg;
?? echo"$msg";
?? die();
? }
? function dbfetch_array($sql,$dbbase,$type){
?? $query_id=$this->dbquery($sql,$dbbase);
?? $this->numrows=mysql_num_rows($query_id);
?? for($i=0;$i<$this->numrows;$i++){
??? if($type==0)
???? $array[$i]=mysql_fetch_array($query_id);
??? else
???? $array[$i]=mysql_fetch_array($query_id);
?? }
?? $this->dbfree_result($query_id);
?? return $array;
? }
? function dbdelete($sql,$dbdase){
?? $query_id=$this->dbquery($sql,$dbbase);
?? $this->affected_rows=mysql_affected_rows($this->dbLink);
?? $this->free_reuslt($query_id);
? }
? function dbinsert($sql,$dbbase){
?? $query_id=$this->dbquery($sql,$dbbase);
?? $this->insert_id=mysql_insert_id($this->dbLink);
?? $this->affected_rows=mysql_affected_rows($this->dbLink);
?? $this->free_reuslt($query_id);
? }
? function dbupdate($sql,$dbbase){
?? $query_id=$this->dbquery($sql,$dbbase);
?? $this->insert_id=mysql_insert_id($this->dbLink);
?? $this->affected_rows=mysql_affected_rows($this->dbLink);
?? $this->free_reuslt($query_id);
? }
? function dbcount_records($table,$index="id",$where="",$dbbase){
?? if($dbbase!="")$this->dbchangedb($dbbase);
?? $result=@mysql_query("select count(".$index.") as 'num' form".$table."where".$where,$this->dbLink);
?? if(!$result) $this->dbhalt("wrong sql sentence".$sql);
??? $num=@mysql_result($result,0,"num");
?? return $num;
? }
? function dbgetnum($result){
?? $num=@mysql_numrows($result);
?? return $num;
? }
? function dbfree_result($result_id){
?? @mysql_free_result($query_id);
? }
? function dbclose(){
?? mysql_close($this->dbLink);
? }
?} // end class
?$db=new db_Mysql;
?$db->dbServer="localhost";
?$db->dbUser="root";
?$db->dbPwd="";
?$db->dbbase="test";

?>

?

posted on 2008-05-24 20:08 allic 閱讀(234) 評論(0) 編輯收藏所屬分類: PHP+MySQL開發(fā)

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發(fā)表評論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關(guān)文章: 判斷終端是來自手機 MySQL修改root密碼的各種方法整理 Linux下兩個不同版本Mysql的安裝實戰(zhàn)（Mysql5和mysql4） apache 配置gzip壓縮簡潔、明晰！數(shù)據(jù)庫設(shè)計三大范式應(yīng)用實例剖析 Mysql中的臨時表如何在mysql中創(chuàng)建內(nèi)存表 php下操作sqlite的一個類 PHP生成縮略圖的實現(xiàn) 用戶登錄

一江春水向東流

常用鏈接

留言簿(12)

隨筆分類(23)

隨筆檔案(42)

文章分類(162)

文章檔案(139)

新聞檔案(10)

相冊

收藏夾(3)

文章收集

搜索

最新評論

閱讀排行榜

評論排行榜