import pymysql

import pymysql.cursors

# 连接数据库

connect = pymysql.Connect(

    host='10.10.146.28',

    port=3306,

    user='admin_m',

    passwd='fcfmTbRw1tz2x5L5GvjJ',

    db='test',

    charset='utf8mb4'

)

def create_table():

    cursor = connect.cursor()

    # 使用execute()方法执行SQL,如果表存在就删除

    cursor.execute("drop table if exists employee")

    # 使用预处理器语句创建表

    sql ="""CREATE TABLE employee(

    id int not null auto_increment,

    first_name varchar(20) not null,

    last_name varchar(20) not null,

    age int not null default 0,

    sex int not null default '0',

    income decimal not null default 0.00,

    create_time datetime,

    primary key(id)

    ) Engine=InnoDB DEFAULT CHARSET=utf8mb4 comment="员工表"

    """

    try:

        cursor.execute(sql)

        print("CREATE TABLE employee success.")

    except Exception as e:

        print("CREATE TABLE employee failed, CASE:%s" % e)

    finally:

        cursor.close()

        # 关闭数据库连接

def main():

    create_table()

if __name__ == "__main__":

    main()