- 若向数据库表插入多行记录，则使用
values；插入一行则用value。
python3如何安装pymysql模块？
①打开cmd：输入命令：pip检查自己安装了pip环境，并添加到环境变量中。有如下提示说明环境正常：
pip正常显示
- 温馨提示：pip是安装python3软件时自带的，只要在安装python3时注意勾选一些选项即可自动安装pip程序！
pip已安装
②检验是否有pymysql模块，以下2种情况都说明没有下载安装pymysql模块。
图一
图二
③窗口切换到 cmd，输入命令：pip install pymysql，之后有如下情况则表示pymysql模块成功安装。
成功安装图1
成功安装图2
- 数据库连接和测试：
import pymysql
def main():
try:
# 打开数据库连接(服务器地址，端口号，用户名，密码，数据库名，连接编码)
conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', password='123456', database='myblog', charset='utf8')
t_cursor = conn.cursor() # 使用该连接创建并返回游标
sql = "SELECT `article_id`, `author`, `key_word`, `article_title`, `start_time`, `article_content` FROM `myblog`.`t_article`;"
t_cursor.execute(sql) # 执行sql语句
data_all = t_cursor.fetchall() # 使用fetchall()返回多个元组，即返回多条记录(rows)。若没有结果,则返回()。
if t_cursor.rowcount == 0: # 获取执行影响的行数rowcount
print("查询结果为空！！！")
else:
for data_one in data_all:
print(data_one)
except pymysql.Error as e:
print('error：', e)
finally:
t_cursor.close() # 关闭游标对象
conn.close() # 关闭连接
if __name__ == '__main__':
main()
- 查询结果如图所示：
数据库查询
- 数据库的
增删改需要用到事务操作（提交和回滚）！！！
数据库表
import pymysql
# 封装pymysql数据库操作
class MySQLCommand(object):
# 类初始化
def __init__(self):
self.host = '127.0.0.1' # 服务器地址
self.port = 3306 # 端口号
self.user = 'root' # 用户名
self.password = '123456' # 密码
self.database = 'myblog' # 数据库名
self.charset = 'utf8' # 连接编码
self.conn = None # 空连接
self.cursor = None # 指向空
# 连接数据库
def get_conn(self):
try:
self.conn = pymysql.connect(
host=self.host,
port=self.port,
user=self.user,
password=self.password,
database=self.database,
charset=self.charset
)
self.cursor = self.conn.cursor() # 获取游标操作
except pymysql.Error as e:
print("error: %s" % (e, ))
# 查询数据
def query_tb(self, _sql):
try:
self.cursor.execute(_sql)
rows = self.cursor.fetchall()
if self.cursor.rowcount == 0:
print("查询结果为空！")
else:
print("查询结果集如下：")
for row in rows:
print(row)
except pymysql.Error as e:
print("error: %s" % (e, ))
# 插入数据
def insert_tb(self, _sql):
try:
self.cursor.execute(_sql)
self.conn.commit() # 提交事务，不然没有效果
if self.cursor.rowcount == 0:
print("插入失败！")
else:
print("插入成功！")
except pymysql.Error as e:
self.conn.rollback() # 出错则事务回滚
print("error: %s" % (e, ))
# 更新数据
def update_tb(self, _sql):
try:
self.cursor.execute(_sql)
self.conn.commit() # 提交事务，不然没有效果
if self.cursor.rowcount == 0:
print("更新失败！")
else:
print("更新成功！")
except pymysql.Error as e:
self.conn.rollback() # 出错则事务回滚
print("error: %s" % (e, ))
# 删除数据
def delete_tb(self, _sql):
try:
self.cursor.execute(_sql)
self.conn.commit() # 提交事务，不然没有效果
if self.cursor.rowcount == 0:
print("删除失败！")
else:
print("删除成功！")
except pymysql.Error as e:
self.conn.rollback() # 出错则事务回滚
print("error: %s" % (e, ))
# 关闭数据库连接
def close_conn(self):
try:
if self.cursor: # 先关闭游标
self.cursor.close()
print("游标已关闭！")
if self.conn: # 再关闭数据库连接
self.conn.close()
print("数据库链接已关闭！")
except pymysql.Error as e:
print("error: %s" % (e, ))
def main():
op_mysql = MySQLCommand()
op_mysql.get_conn() # 链接数据库
# 1、测试查询数据
# t_sql = "SELECT `image_id`,`name1`,`image_url` FROM `myblog`.`t_image` LIMIT 0, 1000 ;"
# op_mysql.query_tb(t_sql)
# 2、测试插入数据
# t_sql = "INSERT INTO `myblog`.`t_image` (`name1`, `image_url`) VALUES('zhangsan1', 'https://www.baidu.com');"
# op_mysql.insert_tb(t_sql)
# 3、测试更新数据
# t_sql = "UPDATE `myblog`.`t_image` SET `name1` = '简书', `image_url` = 'https://www.jianshu.com/p/a23f414cc2f2'
# WHERE `image_id` = 3;"
# op_mysql.update_tb(t_sql)
# 4、测试删除数据
# t_sql = "DELETE FROM `myblog`.`t_image` WHERE `image_id` = 2;"
# op_mysql.delete_tb(t_sql)
op_mysql.close_conn() # 关闭连接
if __name__ == '__main__':
main()
python3如何安装redis模块？
- 按
win+r键：输入cmd调用命令行窗口，输入pip list查看是否已安装redis模块，没有的话输入命令：pip install redis。
安装redis模块
导入redis模块
