本文实例讲述了Python3实现的Mysql数据库操作封装类。分享给大家供大家参考,具体如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
#encoding:utf-8
#name:mod_db.py
'''''
使用方法:1.在主程序中先实例化DB Mysql数据库操作类。
2.使用方法:db=database() db.fetch_all("sql")
'''
import MySQLdb
import MySQLdb.cursors
import mod_config
import mod_logger
DB = "database"
LOGPATH = mod_config.getConfig( 'path' , 'logpath' ) + 'database.log'
DBNAME = mod_config.getConfig(DB, 'dbname' )
DBHOST = mod_config.getConfig(DB, 'dbhost' )
DBUSER = mod_config.getConfig(DB, 'dbuser' )
DBPWD = mod_config.getConfig(DB, 'dbpassword' )
DBCHARSET = mod_config.getConfig(DB, 'dbcharset' )
DBPORT = mod_config.getConfig(DB, "dbport" )
logger = mod_logger.logger(LOGPATH)
#数据库操作类
class database:
#注,python的self等于其它语言的this
def __init__( self , dbname = None , dbhost = None ):
self ._logger = logger
#这里的None相当于其它语言的NULL
if dbname is None :
self ._dbname = DBNAME
else :
self ._dbname = dbname
if dbhost is None :
self ._dbhost = DBHOST
else :
self ._dbhost = dbhost
self ._dbuser = DBUSER
self ._dbpassword = DBPWD
self ._dbcharset = DBCHARSET
self ._dbport = int (DBPORT)
self ._conn = self .connectMySQL()
if ( self ._conn):
self ._cursor = self ._conn.cursor()
#数据库连接
def connectMySQL( self ):
conn = False
try :
conn = MySQLdb.connect(host = self ._dbhost,
user = self ._dbuser,
passwd = self ._dbpassword,
db = self ._dbname,
port = self ._dbport,
cursorclass = MySQLdb.cursors.DictCursor,
charset = self ._dbcharset,
)
except Exception,data:
self ._logger.error( "connect database failed, %s" % data)
conn = False
return conn
#获取查询结果集
def fetch_all( self , sql):
res = ''
if ( self ._conn):
try :
self ._cursor.execute(sql)
res = self ._cursor.fetchall()
except Exception, data:
res = False
self ._logger.warn( "query database exception, %s" % data)
return res
def update( self , sql):
flag = False
if ( self ._conn):
try :
self ._cursor.execute(sql)
self ._conn.commit()
flag = True
except Exception, data:
flag = False
self ._logger.warn( "update database exception, %s" % data)
return flag
#关闭数据库连接
def close( self ):
if ( self ._conn):
try :
if ( type ( self ._cursor) = = 'object' ):
self ._cursor.close()
if ( type ( self ._conn) = = 'object' ):
self ._conn.close()
except Exception, data:
self ._logger.warn( "close database exception, %s,%s,%s" % (data, type ( self ._cursor), type ( self ._conn)))
|
这段代码需要注意几个地方:
1.数据库配置文件变量放在类外面,只在模块被载入的时候读一次,在使用数据库类时,无需再读取。这样有一个好处就是减少了IO的操作。如果是脚本程序需要不停的扫数据库,放在类初始化的时候读数据库配置,那么很有可能造成IO错误,或者读到的section为空,从而导致程序down掉。不好的地方就是如果修改了config,无法及时更新。不过一般程序部署后,不会随意修改config文件,或者在修改config文件后,重新启动程序。不过从程序的健壮性考虑,可以在可能会抛出异常的地方try,catch一下,更好的办法是,在mod_config.py模块中判断一下该section和key是否存在,然后再读取。
2.数据库类在初始化的时候,就将游标赋给它,而不是在进行数据库操作的时候再寻找游标。
PS:在主程序中先实例化DB Mysql数据库操作类。再进行方法使用!
希望本文所述对大家Python程序设计有所帮助。
原文链接:https://blog.csdn.net/m0_37995876/article/details/79991081