本文实例讲述了python访问mysql封装的常用类。分享给大家供大家参考。具体如下:: i5 @# p6 S6 W; S4 r
python访问mysql比较简单,下面整理的就是一个很简单的python访问mysql数据库类。$ }3 l8 o5 v- ]$ Y9 E& x
自己平时也就用到两个mysql函数:查询和更新,下面是自己常用的函数的封装,大家拷贝过去直接可以使用。
2 n$ P/ o0 M a1 n" s8 c9 J' q/ j文件名:dbutil.py
2 _$ @0 d6 z5 B+ N: A7 ]4 ^; \复制代码 代码如下:# -*- encoding:utf8 -*-5 Z; N) _2 u" @$ ]
'''
$ z3 g/ ~3 [ l; Y@author: crazyant.net: g0 m9 `3 w* Z5 M; W S0 O
@version: 2013-10-22+ Z/ F. @9 e9 T) ]& V1 N
封装的mysql常用函数
+ { v: c! s+ h& p# j! |: ['''
: `5 q/ b2 }* N2 g$ ]import mysqldb3 W! O; H. h% B
class db():
- k0 t! O! l5 r' q2 T) Rdef __init__(self, db_host, db_port, db_user, db_pwd, db_name):
$ P0 w. A% X1 A+ i+ K2 n' @4 eself.db_host = db_host2 f/ l, a0 A. i, r) K: ^0 h8 I) }
self.db_port = db_port
% e8 j" U# N; kself.db_user = db_user
! h/ I) s; y% {2 e' zself.db_pwd = db_pwd5 Q2 T. Z8 C5 x
self.db_name = db_name4 {- x+ u' u) J
self.conn = self.getconnection()
# w4 R: I" R% {9 D/ |# W+ \def getconnection(self):
8 p$ \1 }+ R( I* O" j2 Mreturn mysqldb.connect(
( Y! ~* i' @" `# r: k+ t$ r+ ?host=self.db_host, #设置mysql地址! y1 ?- E+ {1 X/ d
port=self.db_port, #设置端口号( U) j- F& E+ O7 C' [* ]2 |. ^
user=self.db_user, #设置用户名
9 i' |9 Z; C; s" [passwd=self.db_pwd, #设置密码$ v' n7 F: f4 O% e
db=self.db_name, #数据库名
& d# B" w# K5 ?* u- Qcharset='utf8' #设置编码0 m) o7 d2 @1 G$ y! Y8 T
): l! O& a# A5 A/ v' G1 ?* F0 u
def query(self, sqlstring):0 d' J8 L& @* G" L) m/ k
cursor=self.conn.cursor()
% t' Y* k2 |3 i3 k% B5 [cursor.execute(sqlstring); D& k, l8 }8 I
returndata=cursor.fetchall()$ X8 l3 T6 k- j# Q- d% x
cursor.close()
7 f, w$ D/ s8 Jself.conn.close()* m q3 e) v$ R( [, d
return returndata% n) }# L; p3 }
def update(self, sqlstring):
+ c& F) ~. p W! B( N1 d5 r1 V# Ocursor=self.conn.cursor()9 F1 c" c+ i) Z: K, j2 A1 ^
cursor.execute(sqlstring)+ ]9 R, v* D1 y' S1 c# o5 r4 `
self.conn.commit()% T& C) g: F8 m* j" _" G
cursor.close()2 x/ g- ?; @. L* X! T3 o9 `
self.conn.close()& {% f+ o' S1 e% m; L4 ~
if __name__==__main__:
) N2 D/ j% R1 D4 W1 ^+ cdb=db('127.0.0.1',3306,'root','','wordpress')
$ u' x5 Y; N3 g# J! I! P2 oprint db.query(show tables;), d& t+ @5 e4 x- ]8 f
使用方法为文件下面的main函数,使用query执行select语句并获取结果;或者使用update进行insert、delete等操作。
, K S; ]% [9 N" U: W; T希望本文所述对大家的python程序设计有所帮助。' \( E8 s4 W4 S( Q% [
! m/ x: u7 P2 B' l更多网页制作信息请查看: 网页制作 |
|