使用python的pymsql连接mysql操作数据(源码复制即用)



import pymysql


class OperationMysql:

    #初始化连接信息
    def __init__(self):
        # 创建一个连接数据库的对象
        self.conn = pymysql.connect(
            host='127.0.0.1',  # 连接的数据库服务器主机名
            port=3306,  # 数据库端口号
            user='root',  # 数据库登录用户名
            passwd='root',
            db='bf',  # 数据库名称
            charset='utf8',  # 连接编码
            cursorclass=pymysql.cursors.DictCursor
        )
        # 使用cursor()方法创建一个游标对象,用于操作数据库
        self.cur = self.conn.cursor()



    # 查询数据
    def search_one(self, sql):
        self.cur.execute(sql)
        result = self.cur.fetchone()  # 使用 fetchone()方法获取单条数据.只显示一行结果
        #result = self.cur.fetchall()  # 显示所有结果
        return result


    #删除数据
    def del_one(self,sql):
        try:
            self.cur.execute(sql)
            #关闭连接
            self.conn.connect()
        except:
            print("执行失败")
            self.conn.rollback()
        #就算失败也关闭数据库
        self.conn.connect();


#main
if __name__ == '__main__':
    #创建对象
    op_mysql = OperationMysql()

    #查询测试
    res = op_mysql.search_one("SELECT * FROM blog")
    print(res)


    #删除测试
    OperationMysql.del_one("DELETE FROM admin WHERE id =2")

    #插入和修改也是一样可以自己试一下
    


 提示:

这里需要改成你自己的数据库连接信息。 

 

 


版权声明:本文为weixin_65451442原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。