博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
django-pymysql-封装的sql使用
阅读量:6710 次
发布时间:2019-06-25

本文共 2311 字,大约阅读时间需要 7 分钟。

封装的sql

import pymysqldef get_list(sql,args):    conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='s4db65', charset='utf8')    cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)    cursor.execute(sql,args)    result = cursor.fetchall()    cursor.close()    conn.close()    return resultdef get_one(sql,args):    conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='s4db65', charset='utf8')    cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)    cursor.execute(sql,args)    result = cursor.fetchone()    cursor.close()    conn.close()    return resultdef modify(sql,args):    conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='s4db65', charset='utf8')    cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)    cursor.execute(sql,args)    conn.commit()    cursor.close()    conn.close()def create(sql,args):    conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='s4db65', charset='utf8')    cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)    cursor.execute(sql,args)    conn.commit()    last_row_id = cursor.lastrowid    cursor.close()    conn.close()    return last_row_idclass SqlHelper(object):    def __init__(self):        # 读取配置文件        self.connect()    def connect(self):        self.conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='s4db65', charset='utf8')        self.cursor = self.conn.cursor(cursor=pymysql.cursors.DictCursor)    def get_list(self,sql,args):        self.cursor.execute(sql,args)        result = self.cursor.fetchall()        return result    def get_one(self,sql,args):        self.cursor.execute(sql,args)        result = self.cursor.fetchone()        return result    def modify(self,sql,args):        self.cursor.execute(sql,args)        self.conn.commit()    def multiple_modify(self,sql,args):        # self.cursor.executemany('insert into bd(id,name)values(%s,%s)',[(1,'alex'),(2,'eric')])        self.cursor.executemany(sql,args)        self.conn.commit()    def create(self,sql,args):        self.cursor.execute(sql,args)        self.conn.commit()        return self.cursor.lastrowid    def close(self):        self.cursor.close()        self.conn.close()

 

转载于:https://www.cnblogs.com/bingabcd/p/7275685.html

你可能感兴趣的文章
Linux IO接口 监控 (iostat)
查看>>
Hadoop阅读笔记(三)——深入MapReduce排序和单表连接
查看>>
poj 3026 Borg Maze(bfs+最小生成树)
查看>>
005-请说一说黑盒与白盒的测试方法
查看>>
分页标签字符串生成方法
查看>>
mediascanner流程
查看>>
Linux学习笔记--进程间通信
查看>>
为什么java web项目中要使用spring
查看>>
初赛小知识之存储器
查看>>
Chosen三级联动
查看>>
node安装和npm全局配置
查看>>
python新式类与旧式类
查看>>
js 事件模型
查看>>
Ubuntu 16.04 不能用inittab 设置 运行等级 runlevel
查看>>
asp.net源码坊2015-3月第二周TOP10下载排行
查看>>
看啦这么就别人的博客 我也来写一篇! Object转换其他类型
查看>>
UICollectionView官方使用示例代码研究
查看>>
Set接口
查看>>
java类库 collection与collections (转)
查看>>
关于在微信支付接口和支付宝接口中使用到的辅助函数
查看>>