1.sql語句參數(shù)化

創(chuàng)建testInsertParam.py文件，向?qū)W生表中插入一條數(shù)據(jù)#encoding=utf-8

import pymysql

try:

conn=pymysql.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8')

cs1=conn.cursor()

students_n=input("請(qǐng)輸入學(xué)生姓名：")

params=[students_n]????#將輸入的要操作的值放入列表中

count=cs1.execute('insert into students(sname) values(%s)',params)

#不管values對(duì)應(yīng)的值是什么類型，都用%s占位符表示

print(count)

conn.commit()

cs1.close()

conn.close()

except Exception as e:

print(e.message)

2.封裝

觀察前面的文件發(fā)現(xiàn)，除了sql語句及參數(shù)不同，其它語句都是一樣的。為了方便，我們可以創(chuàng)建MysqlHelper.py文件，定義類，將這些重復(fù)性語句進(jìn)行封裝。#encoding=utf8

import pymysql

class MysqlHelper():

#定義初始化函數(shù)

def __init__(self,host,port,db,user,passwd,charset='utf8'):

self.host=host

self.port=port

self.db=db

self.user=user

self.passwd=passwd

self.charset=charset

#定義連接函數(shù)，用于創(chuàng)建連接對(duì)象和游標(biāo)對(duì)象

def connect(self):

self.conn=pymysql.connect(host=self.host,port=self.port,db=self.db,user=self.user,passwd=self.passwd,charset=self.charset)

self.cursor=self.conn.cursor()

#定影關(guān)閉函數(shù)，用于關(guān)閉連接對(duì)象和游標(biāo)對(duì)象

def close(self):

self.cursor.close()

self.conn.close()

#獲取一條查詢數(shù)據(jù)

def get_one(self,sql,params=()):

result=None

try:

self.connect()

self.cursor.execute(sql, params)

result = self.cursor.fetchone()

self.close()

#此處的close()是調(diào)用了本類中的close()函數(shù)

except Exception, e:

print e.message

return result

#獲取多條查詢數(shù)據(jù)

def get_all(self,sql,params=()):

list=()

#定義list為空元組

try:

self.connect()

self.cursor.execute(sql,params)

list=self.cursor.fetchall()

self.close()

except Exception,e:

print e.message

return list

#定義編輯函數(shù)，用于對(duì)數(shù)據(jù)庫的增刪改操作

def __edit(self,sql,params):

count=0

try:

self.connect()

count=self.cursor.execute(sql,params)

self.conn.commit()

self.close()

except Exception,e:

print e.message

return count

def insert(self,sql,params=()):

return self.__edit(sql,params)

def delete(self, sql, params=()):

return self.__edit(sql, params)

def update(self, sql, params=()):

return self.__edit(sql, params)

3.調(diào)用封裝類完成數(shù)據(jù)庫操作

(1)創(chuàng)建testInsertWrap.py文件，使用封裝好的幫助類完成插入操作

#encoding=utf8

from MysqlHelper import *

sql='insert into students(sname,gender) values(%s,%s)'

sname=input("請(qǐng)輸入用戶名：")

gender=input("請(qǐng)輸入性別，1為男，0為女")

params=[sname,bool(gender)]

mysqlHelper=MysqlHelper('localhost',3306,'test1','root','mysql')

count=mysqlHelper.insert(sql,params)

if count==1:

print('ok')

else:

print('error')? ? (2)創(chuàng)建testGetOneWrap.py文件，使用封裝好的幫助類完成查詢最新一行數(shù)據(jù)操作

#encoding=utf8

from MysqlHelper import *

sql='select sname,gender from students order by id desc'

helper=MysqlHelper('localhost',3306,'test1','root','mysql')

one=helper.get_one(sql)

print(one)

總結(jié)

以上是生活随笔為你收集整理的mysql 参数化 c_MySQL（16）：参数化、封装的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。