如何使用python连接mysql数据库

如何使用python连接mysql数据库

1.要想让python能够连接到mysql,首先就是要先下载安装pymysql的模块:
Win+R 进入命令行,使用pip install pymysql安装模块。我这里使用的是清华镜像源。
2.导入pymysql模块,创建一个连接mysql的类对象,并定义初始化需要的变量。

#导入pymsql模块
import pymysql

#创建连接MYSQL的类
class TestMysql:

    #初始化变量
    def __init__(self,username,host,passwd,database):
        self.username = username
        self.host = host
        self.passwd = passwd
        self.database = database

3.创建一个连接mysql的connection函数。

    #创建数据库连接
    def conn_mysql(self):
        conn = pymysql.connect(user=self.username,host=self.host,password=self.passwd,db=self.database)
        return conn

4.创建一个mysql退出是的提示信息(个人觉得可以看心情选择)。

    #关闭数据库的提示信息
    def close_mysql(self):
        print("MySQL is Closed")

5.最后在创建一个查询数据的函数,我这里偷懒了,加了一个while循环,每循环一次的时候就询问一次是否继续?这样就可以不用再创建诸如delete,update,insert等等的函数了。

    #查询数据
    def get_data(self):
        self.conn = self.conn_mysql()
        cur = self.conn.cursor()
        #
        while True:
            sql = input('输入SQL语句:')
            cur.execute(sql)
            results = cur.fetchall()
            for i in results:
                print(str(i))   
            yn = input('按N断开连接,任意键继续:').strip()
            if yn == 'N':
                break
        #
        cur.close()
        self.close_mysql()

6.最最最后,为了以后可以在其他程序中调用这个类对象,还可以加上if name == “main”:
下面就是定义变量,创建类的实例,调用实例了。这里我还用了try/except做报错自动处理,当定义的变量有问题出现报错时,会自动将错误信息输出到终端。

if __name__ == "__main__":
    #定义变量
    username = input('用户名:').strip()
    host = input('主机名:').strip()
    passwd = input('密码:').strip()
    database = input('库名:').strip()
    #使用try--except
    try:
        #创建TestMysql的实例
        mysql = TestMysql(username,host,passwd,database)
        mysql.conn_mysql()
        mysql.get_data()
    except pymysql.err.ProgrammingError as e:
        print("Exception Error is %s"%(e))
    except pymysql.err.OperationalError as e:
        print("Exception Error is %s"%(e))

以下是部分运行的效果:

来源:藝海☜☞朝阳

物联沃分享整理
物联沃-IOTWORD物联网 » 如何使用python连接mysql数据库

发表评论