Python中的pymysql模块连接MySQL数据库，并创建表和插入数据

这个实例演示了如何使用Python中的pymysql模块连接MySQL数据库，并创建表和插入数据。具体步骤如下：

1. 首先需要安装pymysql模块，可以使用pip install pymysql命令进行安装。

2. 导入pymysql模块，并使用connect()方法连接数据库。

3. 使用cursor()方法创建游标对象。

4. 使用execute()方法执行SQL语句，创建表或插入数据。

5. 使用commit()方法提交事务。

6. 最后关闭数据库连接。

下面是具体的代码和运行结果：

建立表：

import pymysql

打开数据库连接

db = pymysql.connect(“localhost”,“root”,“root”,“db_test01” )

使用 cursor() 方法创建一个游标对象 cursor

cursor = db.cursor()

使用 execute() 方法执行 SQL，如果表存在则删除

cursor.execute(“DROP TABLE IF EXISTS EMPLOYEE”)

使用预处理语句创建表

sql = “”“CREATE TABLE EMPLOYEE ( FIRST_NAME CHAR(20) NOT NULL, LAST_NAME CHAR(20), AGE INT,
SEX CHAR(1), INCOME FLOAT )”“”

cursor.execute(sql)

print(“CREATE TABLE OK”)

关闭数据库连接

db.close()

运行结果：

CREATE TABLE OK

插入数据：

import pymysql

打开数据库连接

db = pymysql.connect(“localhost”,“root”,“root”,“db_test01” )

使用cursor()方法获取操作游标

cursor = db.cursor()

SQL 插入语句

sql = “INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES (‘%s’, ‘%s’, ‘%d’, ‘%c’, ‘%d’ )” %
(‘Mac’, ‘Mohan’, 20, ‘M’, 2000)

try:

执行sql语句

cursor.execute(sql)

提交到数据库执行

db.commit() print(“insert ok”) except:

如果发生错误则回滚

db.rollback()

关闭数据库连接

db.close()