python3.6 使用 pymysql 连接 Mysql 数据库

windows里的JetBrains PyCharm 2018.2.3软件安装pymysql模块后，即可连接数据库进行调试。

选择软件菜单---File | Settings | Project Interpreter -->点+号 --> 再搜pymysql 然后安装上去就可以了

一、连接库查询记录

# 导入 pymysql模块
import pymysql
# 打开数据库连接
db= pymysql.connect(host="192.168.3.210",user="root",password="dfsfdfe",db="world",port=3306)
# 使用cursor()方法获取操作游标
cur1 = db.cursor()
cur2 = db.cursor()
# 自定义查询语句
sql = "show tables;"       # 查看库中已有表
sql2 = "select ID,Name,CountryCode from city;"  # 查看city表记录
try:
# 执行查询语句1
    cur1.execute(sql)
# 获取查询结果1
    res1 = cur1.fetchall()
# 输出查询结果1
    print(res1)

# 执行查询结果2
    cur2.execute(sql2)
# 获取查询结果2
    res2 = cur2.fetchall()
# 输出查询结果2
    print("ID","Name","CountryCode")
    for row  in res2 :
        ID = row[0]
        Name = row[1]
        CountryCode = row[2]
        print( ID,Name,CountryCode)
except Exception as e:
    raise   e
finally:
# 关闭连接
    db.close()

二、插入记录

# 导入 pymysql模块
import pymysql
# 打开数据库连接
db= pymysql.connect(host="192.168.0.210",user="root",password="JKYjky",db="world",port=3306)
# 使用cursor()方法获取操作游标
cur1 = db.cursor()
# 自定义查询语句
sql_insert = """insert into city(Name,CountryCode,District,Population) value ("ddd","IDN","iiii",22)"""  # 查看city表记录
try:
# 执行并提交查询语句1
    cur1.execute(sql_insert)
    db.commit()
except Exception as e:
# 执行失败就回滚
    db.rollback()
finally:
# 关闭连接
    db.close()

三、更新记录

# 导入 pymysql模块
import pymysql
# 打开数据库连接
db= pymysql.connect(host="192.168.0.210",user="root",password="JKYjky",db="world",port=3306)
# 使用cursor()方法获取操作游标
cur1 = db.cursor()
# 自定义查询语句
sql_update ="update user set username = '%s' where id = %d"
try:
# 执行并提交查询语句1
	cur.execute(sql_update % ("online",3))  #像sql语句传递参数
    db.commit()
except Exception as e:
# 执行失败就回滚
    db.rollback()
finally:
# 关闭连接
    db.close()

四、删除记录

# 导入 pymysql模块
import pymysql
# 打开数据库连接
db= pymysql.connect(host="192.168.0.210",user="root",password="JKYjky",db="world",port=3306)
# 使用cursor()方法获取操作游标
cur1 = db.cursor()
# 自定义查询语句
sql_delete ="delete from user where id = %d"
try:
# 执行并提交查询语句1
	cur.execute(sql_delete % (3))  #像sql语句传递参数
    db.commit()
except Exception as e:
# 执行失败就回滚
    db.rollback()
finally:
# 关闭连接
    db.close()