本文实例讲述了python访问mysql封装的常用类。分享给大家供大家参考。具体如下:' x9 h( d9 ?$ P+ g ~) i
python访问mysql比较简单,下面整理的就是一个很简单的python访问mysql数据库类。
2 o. R- `. }% v自己平时也就用到两个mysql函数:查询和更新,下面是自己常用的函数的封装,大家拷贝过去直接可以使用。* W; |% J3 R9 ?+ |# j/ h" O p
文件名:dbutil.py
3 C$ E! n% y" N1 U% Q. C. e$ E复制代码 代码如下:# -*- encoding:utf8 -*-
2 u4 g8 X$ }$ R+ ~; x'''0 E+ t, s) K, f8 T8 ~7 @
@author: crazyant.net
" g4 Q+ W8 z4 O; Y3 X@version: 2013-10-22/ Z4 x, |% ?" L1 y/ k7 I! i
封装的mysql常用函数
6 q: t7 R" _; c+ K- u! J7 ^. j'''
- S: H+ l! H" O" x; f6 i7 I# W4 _& j& W6 dimport mysqldb1 I* B) b1 v$ I" C* l
class db():& D7 ?/ \- z5 {7 f( }
def __init__(self, db_host, db_port, db_user, db_pwd, db_name):6 [$ M T: n& [5 M# e) Q3 Y
self.db_host = db_host3 A0 o) ~) ^2 z) z) w
self.db_port = db_port
- r, l- U! |3 {. c" fself.db_user = db_user1 v$ b; G# q! p6 |" A
self.db_pwd = db_pwd p# w; E' j3 a) p
self.db_name = db_name
- W, R5 J E1 [self.conn = self.getconnection()( m0 v, N9 j3 k1 e& W; Q! a
def getconnection(self):
( z. H- V: W2 r( F zreturn mysqldb.connect(: J4 |1 @6 l) u* F
host=self.db_host, #设置mysql地址
" o7 s' }+ x, K/ V! b- J, m* |port=self.db_port, #设置端口号
( }/ \/ Y! B. ~% `% R$ x5 [- Z1 Zuser=self.db_user, #设置用户名: B+ y+ Y1 R& q; [* e
passwd=self.db_pwd, #设置密码
! J$ u2 |6 D) V) [7 E# Sdb=self.db_name, #数据库名
7 I& F, R6 r. m! }& z! Q# d9 Gcharset='utf8' #设置编码
6 I% P- ~9 Z2 t: T" G9 W' A)& J- U o7 D: Z D7 K. }. c
def query(self, sqlstring):
& `: p( b* g: [0 kcursor=self.conn.cursor()
) c0 ~1 W" _5 `6 Y& [cursor.execute(sqlstring)
4 c8 Z' q) A9 o+ C0 \' Ureturndata=cursor.fetchall()0 r. y; t3 _! z) J/ f
cursor.close(). ~ k9 F& j* n$ ?
self.conn.close()
1 h4 I% l8 Y% Areturn returndata
k6 }& d# m5 G. ldef update(self, sqlstring): X' r! A/ l3 C$ I
cursor=self.conn.cursor(); I2 \% b! B4 Z4 }
cursor.execute(sqlstring)
n1 u1 @; H" F3 Q+ Jself.conn.commit()& G, _9 P- b' z( `1 P5 \* E+ c4 {/ y
cursor.close()
/ s- e6 g2 B aself.conn.close()% _4 i$ n c! O) r3 q/ B6 L
if __name__==__main__:4 E( [" ?" v. ^* g9 T; s2 d
db=db('127.0.0.1',3306,'root','','wordpress')+ J, O/ n7 `, T* h) a9 X
print db.query(show tables;); G, p$ V# c# ^$ z9 A) u
使用方法为文件下面的main函数,使用query执行select语句并获取结果;或者使用update进行insert、delete等操作。6 Y% o# A" y( G; S$ ~/ ]7 a
希望本文所述对大家的python程序设计有所帮助。* D9 a6 U) r# q; ?9 S
& [9 E7 I3 Z p* i更多网页制作信息请查看: 网页制作 |
|