PHP封装了一个DB数据库 mysql 的类

<?php         // 配置数据库      define(&#39;DB_HOST&#39;, &#39;127.0.0.1&#39;);   //服务器地址      define(&#39;DB_USER&#39;, &#39;root&#39;);   //用户名      define(&#39;DB_PASS&#39;, &#39;&#39;);  //密码      define(&#39;DB_DATABASENAME&#39;, &#39;fenxiao&#39;); //数据库      class Dbmysql      {           /*      *变量      **/      private $tablename=""; //表名      private $fieldname="*";      private $conn;      private $where;      private $sql;      function __construct($tablename)      {      //生成一个连接      $this->conn = mysql_connect(DB_HOST, DB_USER, DB_PASS) or die("connect failed" . mysql_error());        //选择数据库      mysql_select_db(DB_DATABASENAME, $this-&gt;conn);       //设置编码格式      mysql_query("SET NAMES utf8");      //var_dump($conn);      $this-&gt;tablename=$tablename;      }      //设置sql语句      private function setsql($sql)      {      $this-&gt;sql=$sql;      }            //设置条件语句      public function where($where)      {      $this-&gt;where=" where ".$where;    return $this;      }   //按指定字段      public function field($keyword)      {      $this-&gt;fieldname=$keyword;      return $this;      }      //设置连接查询表      public function table($table1,$table2,$field,$bool)      {      $this-&gt;tablename="$table1 LEFT JOIN $table2 ON $table1.$field$bool$table2.$field";      //print_r($this-&gt;tablename);      return $this;      }     //设置多表查询      public function addtable($table1,$table2,$field,$bool)      {      $this-&gt;tablename.=" LEFT JOIN $table2 ON $table1.$field$bool$table2.$field";      //print_r($this-&gt;tablename);      return $this;      }   //设置连接查询表      ##SELECT * FROM 【wx_order LEFT JOIN wx_shopcar ON wx_shopcar.oid=wx_order.oid and wx_order.uid=wx_shopcar.uid LEFT JOIN wx_goods ON wx_shopcar.gid=wx_goods.gid】 WHERE wx_order.oid=1 and wx_order.uid=3      public function settable($sql)      {      $this-&gt;tablename=$sql;      //print_r($this-&gt;tablename);      return $this;      }            //查询所有数据库 以数组形式输出      public function select()      {         /**      * 查询数据库中所有的数据      **/      $arr=array();      //执行sql语句      $result = mysql_query("select ".$this-&gt;fieldname." from ".$this-&gt;tablename.$this-&gt;where, $this-&gt;conn);      while ($row = mysql_fetch_assoc($result)) {   array_push($arr, $row);      }     return $arr;       }     //搜索指定字段数据      public function find()      {      //执行sql语句      $result = mysql_query("select ".$this-&gt;fieldname." from ".$this-&gt;tablename.$this-&gt;where, $this-&gt;conn);       $result = mysql_fetch_assoc($result);      return $result;      }   //增加数据到数据库      public function add($data)      {      $keysql='';      $valuesql='';      foreach ($data as $key =&gt; $value) {      $keysql.=",`$key`";      $valuesql.=",'$value'";      }      $keysql=substr($keysql, 1);      $valuesql=substr($valuesql, 1);      $result=mysql_query("insert into `".$this-&gt;tablename."` ($keysql) VALUES($valuesql)");      $id=mysql_insert_id();      //print_r("insert into `".$this-&gt;tablename."` ($keysql) VALUES($valuesql)");      return $id;      }            //修改数据库的内容      public function save($data)      {      $keysql='';      $valuesql='';      foreach ($data as $key =&gt; $value) {      $keysql.=",`$key`='$value'";      }      $keysql=substr($keysql, 1);      //print_r($keysql);      //echo "<br>";      $result=mysql_query("UPDATE `".$this-&gt;tablename."` SET ".$keysql.$this-&gt;where);      //print_r("UPDATE `".$this-&gt;tablename."` SET ".$keysql.$this-&gt;where);      return $result;    }      ##删除数据      public function delete()      {      $result=mysql_query("DELETE FROM $this-&gt;tablename $this-&gt;where");      //print_r("DELETE FROM $this-&gt;tablename $this-&gt;where");      return $result;      }    }    /**     * mysql_fetch_row: 返回单列的各字段 [0]=&gt;"111"     * mysql_fetch_field: 取得字段信息。[0]=&gt;   ['name']=&gt;   object     * mysql_fetch_array    返回数组资料。 [0]=&gt;"asasds"   ['name']=&gt;     */     ?&gt;
© 版权声明
THE END
喜欢就支持一下吧
点赞9 分享