JakobHu 2019-11-06
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()