數據庫封裝mysql,數據庫封裝類作用

本文目錄一覽：

• 1、php封裝一個class類，實現mysql數據庫的增刪改查怎麼操做？
• 2、mysql 的存儲過程可以封裝數據庫操作嗎
• 3、php封裝好的mysql操作庫嗎
• 4、PHP訪問MYSQL數據庫封裝類(附函數說明)
• 5、python如何使用pymysql連接數據庫封裝類
• 6、php封裝一個class類實現mysql數據庫的增刪該查

php封裝一個class類，實現mysql數據庫的增刪改查怎麼操做？

class sqlHelper{ \x0d\x0a public $conn; \x0d\x0a public $dbname=”數據庫名稱”; \x0d\x0a public $username=”數據庫用戶名”; \x0d\x0a public $password=”數據庫密碼”; \x0d\x0a public $host=”localhost”; \x0d\x0a //連接數據庫 \x0d\x0a public function __construct(){ \x0d\x0a $this-conn=mysql_connect($this-host,$this-username,$this-password); \x0d\x0a if(!$this-conn){ \x0d\x0a die(“連接失敗”.mysql_error()); \x0d\x0a } \x0d\x0a mysql_select_db($this-dbname,$this-conn); \x0d\x0a } \x0d\x0a //執行查詢語句 \x0d\x0a public function execute_dql($sql){ \x0d\x0a $res=mysql_query($sql,$this-conn); \x0d\x0a return $res; \x0d\x0a } \x0d\x0a //執行增填改語句 \x0d\x0a public function execute_dml($sql){ \x0d\x0a $b=mysql_query($sql,$this-conn); \x0d\x0a if(!$b){ \x0d\x0a return 3; \x0d\x0a }else{ \x0d\x0a if(mysql_affected_rows($this-conn)){ \x0d\x0a return 1;//表示OK \x0d\x0a }else{ \x0d\x0a return 2;//表示沒有行收到影響 \x0d\x0a } \x0d\x0a } \x0d\x0a }\x0d\x0a}

mysql 的存儲過程可以封裝數據庫操作嗎

存儲過程不存在操作或是不操作觸發器的問題，要先理解觸發器的含義。

觸發器分兩類，一類是基於表數據的觸發，一類是基於數據庫對象的觸發。

實際應用中第一類比較常用，它是在對錶數據進行 插入 修改 刪除 的操作時觸發，執行觸發器中的腳本，換言之，就是如果你的存儲過程有涉及到對該表的 插入 修改 刪除 數據操作，而且該表也存在這些操作對應的觸發器，那麼肯定會觸發也就是執行這個觸發器，反之，不會執行。

php封裝好的mysql操作庫嗎

php封裝好的mysql操作庫

類文件mysql.class.php：

?php

class Mysql{

//數據庫連接返回值

private $conn;

/**

* [構造函數，返回值給$conn]

* @param [string] $hostname [主機名]

* @param [string] $username[用戶名]

* @param [string] $password[密碼]

* @param [string] $dbname[數據庫名]

* @param [string] $charset[字符集]

* @return [null]

*/

function __construct($hostname,$username,$password,$dbname,$charset=’utf8′){

$config = @mysql_connect($hostname,$username,$password);

if(!$config){

echo ‘連接失敗，請聯繫管理員’;

exit;

}

$this-conn = $config;

$res = mysql_select_db($dbname);

if(!$res){

echo ‘連接失敗，請聯繫管理員’;

exit;

}

mysql_set_charset($charset);

}

function __destruct(){

mysql_close();

}

/**

* [getAll 獲取所有信息]

* @param [string] $sql [sql語句]

* @return [array] [返回二維數組]

*/

function getAll($sql){

$result = mysql_query($sql,$this-conn);

$data = array();

if($result mysql_num_rows($result)0){

while($row = mysql_fetch_assoc($result)){

$data[] = $row;

}

}

return $data;

}

/**

* [getOne 獲取單條數據]

* @param [string] $sql [sql語句]

* @return [array] [返回一維數組]

*/

function getOne($sql){

$result = mysql_query($sql,$this-conn);

$data = array();

if($result mysql_num_rows($result)0){

$data = mysql_fetch_assoc($result);

}

return $data;

}

/**

* [getOne 獲取單條數據]

* @param [string] $table [表名]

* @param [string] $data [由字段名當鍵，屬性當鍵值的一維數組]

* @return [type] [返回false或者插入數據的id]

*/

function insert($table,$data){

$str = ”;

$str .=”INSERT INTO `$table` “;

$str .=”(`”.implode(“`,`”,array_keys($data)).”`) “;

$str .=” VALUES “;

$str .= “(‘”.implode(“‘,'”,$data).”‘)”;

$res = mysql_query($str,$this-conn);

if($res mysql_affected_rows()0){

return mysql_insert_id();

}else{

return false;

}

}

/**

* [update 更新數據庫]

* @param [string] $table [表名]

* @param [array] $data [更新的數據，由字段名當鍵，屬性當鍵值的一維數組]

* @param [string] $where [條件，‘字段名’=‘字段屬性’]

* @return [type] [更新成功返回影響的行數，更新失敗返回false]

*/

function update($table,$data,$where){

$sql = ‘UPDATE ‘.$table.’ SET ‘;

foreach($data as $key = $value){

$sql .= “`{$key}`='{$value}’,”;

}

$sql = rtrim($sql,’,’);

$sql .= ” WHERE $where”;

$res = mysql_query($sql,$this-conn);

if($res mysql_affected_rows()){

return mysql_affected_rows();

}else{

return false;

}

}

/**

* [delete 刪除數據]

* @param [string] $table [表名]

* @param [string] $where [條件，‘字段名’=‘字段屬性’]

* @return [type] [成功返回影響的行數，失敗返回false]

*/

function del($table,$where){

$sql = “DELETE FROM `{$table}` WHERE {$where}”;

$res = mysql_query($sql,$this-conn);

if($res mysql_affected_rows()){

return mysql_affected_rows();

}else{

return false;

}

}

}

?

使用案例:

?php

//包含數據庫操作類文件

include ‘mysql.class.php’;

//設置傳入參數

$hostname=’localhost’;

$username=’root’;

$password=’123456′;

$dbname=’aisi’;

$charset = ‘utf8’;

//實例化對象

$db = new Mysql($hostname,$username,$password,$dbname);

//獲取一條數據

$sql = “SELECT count(as_article_id) as count FROM as_article where as_article_type_id=1”;

$count = $db-getOne($sql);

//獲取多條數據

$sql = “SELECT * FROM as_article where as_article_type_id=1 order by as_article_addtime desc limit $start,$limit”;

$service = $db-getAll($sql);

//插入數據

$arr = array(

‘as_article_title’=’數據庫操作類’,

‘as_article_author’=’rex’,

);

$res = $db-insert(‘as_article’,$arr);

//更新數據

$arr = array(

‘as_article_title’=’實例化對象’,

‘as_article_author’=’Lee’,

);

$where = “as_article_id=1”;

$res = $db-update(‘as_article’,$arr,$where);

//刪除數據

$where = “as_article_id=1”;

$res = $db-del(‘as_article’,$where);

?

PHP訪問MYSQL數據庫封裝類(附函數說明)

複製代碼

代碼如下:

?php

/*

MYSQL

數據庫訪問封裝類

MYSQL

數據訪問方式，php4支持以mysql_開頭的過程訪問方式，php5開始支持以mysqli_開頭的過程和mysqli面向對象

訪問方式，本封裝類以mysql_封裝

數據訪問的一般流程：

1,連接數據庫

mysql_connect

or

mysql_pconnect

2,選擇數據庫

mysql_select_db

3,執行SQL查詢

mysql_query

4,處理返回的數據

mysql_fetch_array

mysql_num_rows

mysql_fetch_assoc

mysql_fetch_row

etc

*/

class

db_mysql

{

var

$querynum

=

;

//當前頁面進程查詢數據庫的次數

var

$dblink

;

//數據庫連接資源

//鏈接數據庫

function

connect($dbhost,$dbuser,$dbpw,$dbname=”,$dbcharset=’utf-8′,$pconnect=0

,

$halt=true)

{

$func

=

empty($pconnect)

?

‘mysql_connect’

:

‘mysql_pconnect’

;

$this-dblink

=

@$func($dbhost,$dbuser,$dbpw)

;

if

($halt

!$this-dblink)

{

$this-halt(“無法鏈接數據庫！”);

}

//設置查詢字符集

mysql_query(“SET

character_set_connection={$dbcharset},character_set_results={$dbcharset},character_set_client=binary”,$this-dblink)

;

//選擇數據庫

$dbname

@mysql_select_db($dbname,$this-dblink)

;

}

//選擇數據庫

function

select_db($dbname)

{

return

mysql_select_db($dbname,$this-dblink);

}

//執行SQL查詢

function

query($sql)

{

$this-querynum++

;

return

mysql_query($sql,$this-dblink)

;

}

//返回最近一次與連接句柄關聯的INSERT，UPDATE

或DELETE

查詢所影響的記錄行數

function

affected_rows()

{

return

mysql_affected_rows($this-dblink)

;

}

//取得結果集中行的數目,只對select查詢的結果集有效

function

num_rows($result)

{

return

mysql_num_rows($result)

;

}

//獲得單格的查詢結果

function

result($result,$row=0)

{

return

mysql_result($result,$row)

;

}

//取得上一步

INSERT

操作產生的

ID,只對錶有AUTO_INCREMENT

ID的操作有效

function

insert_id()

{

return

($id

=

mysql_insert_id($this-dblink))

=

?

$id

:

$this-result($this-query(“SELECT

last_insert_id()”),

0);

}

//從結果集提取當前行，以數字為key表示的關聯數組形式返回

function

fetch_row($result)

{

return

mysql_fetch_row($result)

;

}

//從結果集提取當前行，以字段名為key表示的關聯數組形式返回

function

fetch_assoc($result)

{

return

mysql_fetch_assoc($result);

}

//從結果集提取當前行，以字段名和數字為key表示的關聯數組形式返回

function

fetch_array($result)

{

return

mysql_fetch_array($result);

}

//關閉鏈接

function

close()

{

return

mysql_close($this-dblink)

;

}

//輸出簡單的錯誤html提示信息並終止程序

function

halt($msg)

{

$message

=

“html\nhead\n”

;

$message

.=

“meta

content=’text/html;charset=gb2312’\n”

;

$message

.=

“/head\n”

;

$message

.=

“body\n”

;

$message

.=

“數據庫出錯：”.htmlspecialchars($msg).”\n”

;

$message

.=

“/body\n”

;

$message

.=

“/html”

;

echo

$message

;

exit

;

}

}

?

python如何使用pymysql連接數據庫封裝類

1、python安裝目錄設定為d:/python34

2、pymysql安裝方法為：解壓下載的文件，在cmd中運行: python setup.py install。

檢驗安裝安裝是否成功的方法：import pymysql 。 如果不報錯 說明安裝成功。

3、mysql安裝目錄為D:/phpStudy/MySQL。為避免更多配置問題，可在啟動phpstudy後，將其設為系統服務

4、基本操作：

（1）導入pymysql: import pymysql

（2）連接數據庫：

conn=pymysql.connect(host=’localhost’,user=’root’,passwd=’root’,db=’ere’，charset=’utf8′)

務必注意各等號前面的內容！charset參數可避免中文亂碼

（3）獲取操作游標：cur=conn.cursor()

（4）執行sql語句,插入記錄：sta=cur.execute(“insert 語句”) 執行成功後sta值為1。更新、刪除語句與此類似。

（5）執行sql語句，查詢記錄：cur.execute(“select語句”) 執行成功後cur變量中保存了查詢結果記錄集，然後再用循環打印結果：

for each in cur:

print(each[1].decode(‘utf-8’)) # each[1] 表示當前游標所在行的的第2列值，如果是中文則需要處理編碼

php封裝一個class類實現mysql數據庫的增刪該查

?php

class db{

private $db;

const MYSQL_OPT_READ_TIMEOUT = 11;

const MYSQL_OPT_WRITE_TIMEOUT = 12;

private $tbl_name;

private $where;

private $sort;

private $fields;

private $limit;

public static $_instance = null;

function __construct(){

$cfg = loadConfig(‘db’);

$db = mysqli_init();

$db-options(self::MYSQL_OPT_READ_TIMEOUT, 3);

$db-options(self::MYSQL_OPT_WRITE_TIMEOUT, 1);

@$db-real_connect($cfg[‘host’],$cfg[‘user’],$cfg[‘pwd’],$cfg[‘db’]);

if ($db-connect_error) {

$this-crash($db-errno,$db-error);

}

$db-set_charset(“utf8”);

$this-db = $db;

//echo $this-db-stat;

}

public static function getInstance(){

if(!(self::$_instance instanceof self)){

self::$_instance = new self();

}

return self::$_instance;

}

private function __clone() {} //覆蓋__clone()方法，禁止克隆

public function find($conditions = null){

if($conditions) $this-where($conditions);

return $this-getArray($this-buildSql(),1);

}

public function findAll($conditions = null){

if($conditions) $this-where($conditions);

return $this-getArray($this-buildSql());

}

//表

public function t($table){ $this-tbl_name = $table; return $this;}

//條件

public function where($conditions){

$where = ”;

if(is_array($conditions)){

$join = array();

foreach( $conditions as $key = $condition ){

$condition = $this-db-real_escape_string($condition);

$join[] = “`{$key}` = ‘{$condition}'”;

}

$where = “WHERE “.join(” AND “,$join);

}else{

if(null != $conditions) $where = “WHERE “.$conditions;

}

$this-where = $where;

return $this;

}

//排序

public function sort($sort){

if(null != $sort) $sort = “ORDER BY {$sort}”;

$this-sort = $sort;

return $this;

}

//字段

public function fields($fields){ $this-fields = $fields; return $this; }

public function limit($limit){$this-limit = $limit; return $this;}

private function buildSql(){

$this-fields = empty($this-fields) ? “*” : $this-fields;

$sql = “SELECT {$this-fields} FROM {$this-tbl_name} {$this-where} {$this-sort}”;

accessLog(‘db_access’,$sql);

if(null != $this-limit)$sql .= ” limit {$this-limit}”;

return $sql;

}

/**

* 返回查詢數據

* @param $sql

* @param bool $hasOne

* @return array|bool|mixed

*/

private function getArray($sql,$hasOne = false){

if($this-db-real_query($sql) ){

if ($result = $this-db-use_result()) {

$row = array();

if($hasOne){

$row = $result-fetch_assoc();

}else{

while($d = $result-fetch_assoc()) $row[] = $d;

}

$result-close();

$this-fields = “*”;

return $row;

}else{

return false;

}

}else{

if($this-db-error){

$this-crash($this-db-errno,$this-db-error,$sql);

}

}

}

public function findSql($sql,$hasOne = false){

accessLog(‘db_access’,$sql);

if($this-db-real_query($sql) ){

if ($result = $this-db-use_result()) {

$row = array();

if($hasOne){

$row = $result-fetch_assoc();

}else{

while($d = $result-fetch_assoc()) $row[] = $d;

}

$result-close();

$this-fields = “*”;

return $row;

}else{

return false;

}

}else{

if($this-db-error){

$this-crash($this-db-errno,$this-db-error,$sql);

}

}

}

public function create($row){

if(!is_array($row))return FALSE;

$row = $this-prepera_format($row);

if(empty($row))return FALSE;

foreach($row as $key = $value){

$cols[] = ‘`’.$key.’`’;

$vals[] = “‘”.$this-db-real_escape_string($value).”‘”;

}

$col = implode(‘,’, $cols);

$val = implode(‘,’, $vals);

$sql = “INSERT INTO `{$this-tbl_name}` ({$col}) VALUES ({$val})”;

accessLog(‘db_access’,$sql);

if( FALSE != $this-db-query($sql) ){ // 獲取當前新增的ID

if($this-db-insert_id){

return $this-db-insert_id;

}

if($this-db-affected_rows){

return true;

}

}

return FALSE;

}

//直接執行sql

public function runSql($sql){

accessLog(‘db_access’,$sql);

if( FALSE != $this-db-query($sql) ){ // 獲取當前新增的ID

return true;

}else{

return false;

}

}

public function update($row){

$where = “”;

$row = $this-prepera_format($row);

if(empty($row))return FALSE;

foreach($row as $key = $value){

$value = $this-db-real_escape_string($value);

$vals[] = “`{$key}` = ‘{$value}'”;

}

$values = join(“, “,$vals);

$sql = “UPDATE {$this-tbl_name} SET {$values} {$this-where}”;

accessLog(‘db_access’,$sql);

if( FALSE != $this-db-query($sql) ){ // 獲取當前新增的ID

if( $this-db-affected_rows){

return true;

}

}

return false;

}

function delete(){

$sql = “DELETE FROM {$this-tbl_name} {$this-where}”;

if( FALSE != $this-db-query($sql) ){ // 獲取當前新增的ID

if( $this-db-affected_rows){

return true;

}

}

return FALSE;

}

private function prepera_format($rows){

$columns = $this-getArray(“DESCRIBE {$this-tbl_name}”);

$newcol = array();

foreach( $columns as $col ){

$newcol[$col[‘Field’]] = $col[‘Field’];

}

return array_intersect_key($rows,$newcol);

}

//崩潰信息

private function crash($number,$message,$sql=”){

$msg = ‘Db Error ‘.$number.’:’.$message ;

if(empty($sql)){

echo t(‘db_crash’);

}else{

$msg .= ” SQL:”.$sql;

echo t(‘db_query_err’);

}

accessLog(‘db_error’,$msg);

exit;

}

}