pymysql连接mysql指定端口_python 连接mysql数据库:pymysql

示例:import pymysql

conn=pymysql.connect(

host="127.0.0.1", #数据库IP

port=3306, #数据库端口

user="root", #数据库用户名

passwd="root", #数据库密码

db="testman", #连接数据库名

charset="utf8" #数据库字符集

)

cursor=conn.cursor() #使用cursor()方法获取数据库的操作游标(游标是记录操作哪个库、表、字段、时间等信息)

#创建数据库的sql

CreateDatabaseSql="create database if not exists test176 default charset utf8mb4 collate utf8_general_ci;"

#创建表的sql

CreateTableSql="create table tb_user_info (id int(6) not null,login_name varchar(12),pass_word varchar(16),create_date datetime)engine=innodb default charset=utf8mb4;"

#修改表结构sql

AlterSql="alter table tb_user_info add sex varchar2(6);"

#删除表sql

DropSql="drop table tb_user_info;"

#插入数据的sql

InsertSql="insert into tb_user_info values(1,'wq123','123456','2018-12-30');"

#修改表数据

UpdateSql="update tb_user_info set pass_word='123456' where login_name='wq123';"

#删除表数据

DeleteSql="delete from tb_user_info where login_name='wq123';"

#查询表数据

SelectSql="select * from tb_user_info;"

try:

cursor.execute(SelectSql) #SelectSql可以是其他数据库操作变量,执行sql语句,返回的是影响行数

OneData=cursor.fetchone() #一条查询结果,返回类型为tuple

AllData=cursor.fetchall() #所有查询结果,返回类型为tuple:((login_name1,passwd1,),(login_name2,passwd2),),可遍历

conn.commit() #提交操作

cursor.close() #关闭游标

conn.close() #关闭数据库连接

except pymysql.Error as e:

print("mysql error %d:%s" %(e.args[0],e.args[1])) #捕获异常(如数据库无法连接:ip、端口错误等)

conn.rollback() #报错时回退

cursor.close() #关闭游标

conn.close() #关闭数据库连接


版权声明:本文为weixin_31781061原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。