本文实例讲述了python访问mysql封装的常用类。分享给大家供大家参考。具体如下:8 @$ I3 q8 F1 p* \( w2 `
python访问mysql比较简单,下面整理的就是一个很简单的python访问mysql数据库类。
6 z4 A/ H; B7 W& c$ ]自己平时也就用到两个mysql函数:查询和更新,下面是自己常用的函数的封装,大家拷贝过去直接可以使用。" f' C/ N2 m' X8 O& r2 G% x
文件名:dbutil.py
& n' P: |: ]1 e* l6 {3 \3 c复制代码 代码如下:# -*- encoding:utf8 -*-
% j }. M. q1 {) b5 |. ]2 R2 q L'''
( {. H/ I; R0 r8 i0 S; |@author: crazyant.net
0 G, x# i/ j% _$ l$ J+ G@version: 2013-10-22
% b ]4 I: u4 @. P* X封装的mysql常用函数
8 p% f' w- O4 c% k% Z'''
3 f. R6 v( ?) B; Y" V' h+ dimport mysqldb1 G( g2 e) I0 s) e6 ^3 G# z
class db():
) _/ S1 r/ Y3 E zdef __init__(self, db_host, db_port, db_user, db_pwd, db_name):
" J/ G. }- J! K- M1 A( O' M( bself.db_host = db_host
* ]5 e' ^$ {+ ^ nself.db_port = db_port
7 E! M* I5 Q9 ?( E0 H3 Jself.db_user = db_user$ @6 V- O1 \" z4 `6 n8 `) V
self.db_pwd = db_pwd" Q9 f2 h: |$ e8 G+ i
self.db_name = db_name3 l! e6 l5 x4 w3 o. C2 s& G' ^
self.conn = self.getconnection() ^) q7 e% o. o5 F, K0 I3 |
def getconnection(self):0 Z7 `/ T! P7 [3 s2 u8 Y6 [
return mysqldb.connect(4 p: F% Q- ^8 p9 X i0 _
host=self.db_host, #设置mysql地址 J8 z# s% X1 j4 o/ J7 a. d6 I ?- _! d
port=self.db_port, #设置端口号! } S# \% L$ [4 H+ z& ?3 y8 u" [) A
user=self.db_user, #设置用户名) n: E/ v& W1 W; j4 s5 h) _
passwd=self.db_pwd, #设置密码2 R J" ?' ^; n
db=self.db_name, #数据库名
+ f V8 f1 M5 k& p2 f$ s. Acharset='utf8' #设置编码/ J# \7 e) i; y2 \% K
)
+ r0 n* _2 X; E' a% ~0 ?- ^4 Q6 z @def query(self, sqlstring):
( N$ r; K3 n! s/ a* s+ Ccursor=self.conn.cursor()
( v( o6 p# r* e) f4 Zcursor.execute(sqlstring)- c6 H3 Y3 X$ h3 Y( A
returndata=cursor.fetchall()
' e7 k9 Y& Y0 J$ n3 icursor.close()6 Y$ j2 h2 G1 h. \6 Q0 \) K
self.conn.close()5 e/ t$ P" v1 l0 d. I B& n i
return returndata2 g( i& B/ A+ n7 C |
def update(self, sqlstring):$ ~8 `/ _# f' D$ L
cursor=self.conn.cursor()0 i6 L8 z0 c5 N- C
cursor.execute(sqlstring)
1 L+ S% H6 C Q9 u# qself.conn.commit()2 H2 ~3 e( b s! d
cursor.close()
7 y( y8 N) k ]0 E F# r4 z+ Aself.conn.close()
% I6 ^6 U9 d! w+ @& X6 {$ R; }) Tif __name__==__main__:
) Y& R" T' L' e; tdb=db('127.0.0.1',3306,'root','','wordpress')+ }- N N$ q$ z; e4 e/ W
print db.query(show tables;)5 W! x, @2 l3 R ~% C
使用方法为文件下面的main函数,使用query执行select语句并获取结果;或者使用update进行insert、delete等操作。! w7 j) D3 x1 @( `3 F6 J! f
希望本文所述对大家的python程序设计有所帮助。8 Z) u* J* u9 p
2 q% D& a; d# w6 G) P' S. q更多网页制作信息请查看: 网页制作 |
|