代码案例如下：

import pymysql

host = "127.0.0.1"
user = "testuser" # 用户名
password = "testpassword" # 密码
db = "test_db" # 数据库名称

conn = pymysql.connect(host=host, user=user, password=password, database=db) # 连接数据库
cursor = conn.cursor() # 创建游标

try:
    my_sql = """ CREATE TABLE IF NOT EXISTS `test_db`.`new_table`( `col_1` VARCHAR(50) NOT NULL); """

    cursor.execute(my_sql) # 执行sql
    conn.commit()
    cursor.close() # 关闭游标
    conn.close() # 关闭连接
    print("创建成功")
except Exception as e:
    # 失败后的回滚操作
    conn.rollback()
    cursor.close()
    conn.close()
    print("创建失败: ", e)

在try中出错后，会执行except中的conn.rollback()，用来回滚操作，使错误的事物不会对数据库造成影响