安装 pymysql 模块

pip3 install pymysql
# python2, 默认无 pip 命令
# python3, 默认自带 pip3 命令 

mysql基本操作

# 导入 pymysql 模块
import  pymysql

# 创建连接
conn = pymysql.connect(host=\'192.168.0.214\', port=3306, user=\'root\', passwd=\'123456\', db=\'tmpdb\')

# 获取光标
cursor = conn.cursor()

# 插入一行
result = cursor.execute(\"insert into tmp(name) values (%s)\",(\"jim\"))

# 插入多行
result = cursor.executemany(\"insert into tmp(name) values (%s)\",[(\"james1\"),(\"james2\"),(\"james2\")])

# 修改后必须提交
conn.commit()

# 获取一行数据
cursor.execute(\'select * from tmp\')
r = cursor.fetchone()
print(r)

# 获取4行数据
cursor.execute(\'select * from tmp\')
r = cursor.fetchmany(4)
print(r)

# 获取影响的行数
result = cursor.execute(\'select * from tmp\')
print(result)

# 获取所有的值
values = cursor.fetchall()
print(values)

# 把光标移到最开始处
cursor.scroll(0, mode=\'absolute\')

# 关闭光标
cursor.close()

# 关闭连接
conn.close()

在操作mysql中应当禁止使用字符串拼接sql 的方式

# 禁止例子 :
inp = input(\'please input name: \')
sql = \'insert into tmp(name) values(\"%s\")\'
sql = sql %(inp,)
r = cursor.execute(sql)
conn.commit()

# 推荐例子:
inp = input(\'please input name: \')
print(inp, type(inp))
r = cursor.execute(\'insert into tmp(name) values(%s)\', inp)
conn.commit()
收藏 打印