本文实例讲述了python访问mysql封装的常用类。分享给大家供大家参考。具体如下:/ n( w6 o8 N( J3 @: t: W l" H1 N/ t
python访问mysql比较简单,下面整理的就是一个很简单的python访问mysql数据库类。. [' [& m6 [7 a; S% a. [
自己平时也就用到两个mysql函数:查询和更新,下面是自己常用的函数的封装,大家拷贝过去直接可以使用。' X; i& c7 `. c
文件名:dbutil.py0 }: r" V5 H/ F9 F7 L3 C
复制代码 代码如下:# -*- encoding:utf8 -*-2 y& K+ ^; U: y, p5 l
'''
9 U: M3 t7 N. [' ^5 a# L0 a0 }@author: crazyant.net! Z3 y* A2 G- O& ]! D, u
@version: 2013-10-22( @* R% m5 O1 }) l/ I
封装的mysql常用函数
h1 r# D6 R6 d'''! \% w/ }: D* F- X6 u4 N
import mysqldb
4 n: ]# Z9 B3 r" J* f# |5 {class db():
+ c6 B; f1 K) Z9 M; g) C# S- ?def __init__(self, db_host, db_port, db_user, db_pwd, db_name):3 U: A5 d3 Q! u) F _0 G! \: L
self.db_host = db_host; f! d x. M2 R: w7 [4 m0 }# n
self.db_port = db_port
9 J( p! O. j6 ?/ n! T8 y1 l9 Pself.db_user = db_user
. V0 @( W' G9 N1 f' e0 ~2 U! J* ^' M5 sself.db_pwd = db_pwd/ h, p6 X5 z( E) R- Z
self.db_name = db_name
- e- m" D1 P" l; \self.conn = self.getconnection(); q* ^6 n7 E& y9 z _8 c6 ~
def getconnection(self):3 @* t0 |% | f
return mysqldb.connect(
( ]. x v( `+ u* {: bhost=self.db_host, #设置mysql地址 N& V/ p: N! W% J# ^0 L. n W
port=self.db_port, #设置端口号
- M2 L5 R9 ^1 u G" S6 ruser=self.db_user, #设置用户名
" w$ u4 ^ k7 a; m) {' Z6 dpasswd=self.db_pwd, #设置密码$ P4 T9 ]) p' E' f$ u$ O; P
db=self.db_name, #数据库名
5 M' y0 v8 {0 s, {8 l; [8 @charset='utf8' #设置编码
' k0 n6 L: S, N$ r/ j7 d# Y) R1 T4 @3 q. h& Z- ~6 T& C
def query(self, sqlstring):
$ b* A6 t1 B3 `7 s% d+ k, |: s1 Kcursor=self.conn.cursor()
; \; t% |; B$ a: o( p5 U2 Y2 [8 Jcursor.execute(sqlstring)
/ [* Y$ A b/ {1 R5 oreturndata=cursor.fetchall()* Z6 @4 z2 }- l1 m7 t
cursor.close()3 W6 p2 W( ^) x0 F
self.conn.close()
7 I% k$ [" S+ [" k/ Z% a5 qreturn returndata% a( |2 F+ E; Q4 b+ q1 a6 n4 x/ l; g
def update(self, sqlstring):
4 q+ u7 D% k' y% `/ e& Ocursor=self.conn.cursor()
( c, t& T( G# o( ?: {cursor.execute(sqlstring)
8 n0 L/ ^2 S% m7 d% N. A+ ?self.conn.commit()/ v" [6 @6 Y$ n+ T, q
cursor.close()
" u7 w3 ^$ @( n) w* l* Q$ Nself.conn.close()6 k* c7 a$ d0 E( ?
if __name__==__main__:# T2 L6 }7 O' ^5 c$ q9 V( W
db=db('127.0.0.1',3306,'root','','wordpress')
! \5 S& b7 f- Z" W, _5 Qprint db.query(show tables;)
& U6 Q! B8 X2 u使用方法为文件下面的main函数,使用query执行select语句并获取结果;或者使用update进行insert、delete等操作。
! R* {' T% C, y5 ~; ~希望本文所述对大家的python程序设计有所帮助。
9 d( M* P5 c4 @2 n% U/ S C1 j( |
v( D5 `% _, J; j更多网页制作信息请查看: 网页制作 |
|