本文实例为大家分享了python3.4函数操作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
89
90
91
92
93
94
95
96
|
#!/usr/bin/env python
# -*- coding:utf-8 -*-
# __author__ = "blzhu"
"""
python study
Date:2017
"""
# -*- coding: utf-8 -*-
__author__ = 'djstava@gmail.com'
import logging
import pymysql
class MySQLCommand( object ):
def __init__( self , host, port, user, passwd, db, table, charset):
self .host = host
self .port = port
self .user = user
self .password = passwd
self .db = db
self .table = table
self .charset = charset
def connectMysql( self ):
try :
self .conn = pymysql.connect(host = self .host, port = self .port, user = self .user, passwd = self .password,
db = self .db, charset = self .charset)
self .cursor = self .conn.cursor()
print ( 'connect ' + self .table + ' correctly!' )
except :
print ( 'connect mysql error.' )
def queryMysql( self ):
sql = "SELECT * FROM " + self .table
try :
print ( "query Mysql:" )
self .cursor.execute(sql)
#row = self.cursor.fetchone()
for d in self .cursor:
print ( str (d[ 0 ]), str (d[ 1 ]), str (d[ 2 ]))
# print(row)
except :
print (sql + ' execute failed.' )
def insertMysql( self , id , name, sex):
sql = "INSERT INTO " + self .table + " VALUES(" + id + "," + "'" + name + "'," + "'" + sex + "')"
try :
print ( "insert Mysql:" )
self .cursor.execute(sql)
print (sql)
except :
print ( "insert failed." )
def updateMysqlSN( self , name, sex):
sql = "UPDATE " + self .table + " SET sex='" + sex + "'" + " WHERE name='" + name + "'"
print ( "update sn:" + sql)
try :
self .cursor.execute(sql)
self .conn.commit()
except :
self .conn.rollback()
def deleteMysql( self , id ): # 删除
sql = "DELETE FROM %s WHERE id='%s'" % ( self .table, id )
#"delete from student where zid='%s'" % (id)
try :
self .cursor.execute(sql)
print (sql)
self .conn.commit()
print ( "delete the " + id + "th row successfully!" )
except :
print ( "delete failed!" )
self .conn.rollback()
def closeMysql( self ):
self .conn.commit() # 不执行此句,所作的操作不会写入到数据库中
self .cursor.close()
self .conn.close()
if __name__ = = '__main__' :
zblmysql = MySQLCommand(host = 'localhost' , user = 'root' , passwd = 'root' , db = 'zbltest1' , port = 3306 , table = 'student2' ,
charset = 'utf8' )
zblmysql.connectMysql()
zblmysql.queryMysql()
zblmysql.insertMysql( '5' , 'zbl5' , 'man' )
zblmysql.queryMysql()
zblmysql.deleteMysql( id = 2 )
zblmysql.queryMysql()
zblmysql.updateMysqlSN(name = 'zbl5' ,sex = 'woman' )
zblmysql.queryMysql()
zblmysql.closeMysql()
|
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。