[大数据]Python-mysql应用

实际测试或者工作中，有时候会涉及到操作数据库，数据量多的情况下，使用python更加便捷方便。

Python支持很多不同的数据库，如图等等，连接不同的数据库，需要下载不同的API模块。MySQL需要下载MySQL的模块。

?1. 安装模块

python2使用mysqldb，python3用的是PyMySQL

python3中pip install mysql会报错

pip3 install pymsql可以成功

2.?连接数据库

连接数据库之前，需要已经有已启动的数据库，且有对应权限或root权限的账号密码。

1） 导入pymysql:?import?pymysql

2）?连接数据库：conn = connect(host='数据库ip',port=端口号,user='用户名',passwd='数据库密码',database='s数据库名',charset='utf8')

3） 获取到执行sql的光标：cursor = conn.cursor()

4） 定义需要执行的sql：sql =?“sql语句”

5） 执行sql：cursor.execute(sql)

6） 关闭光标：cursor.close（）

7） 关闭数据库：conn.close()

3.?示例

下面是一个通过数据库使用try增加数据库表数据的实例

from pymysql import *

def add_test_up_message():

? ? conn = connect(host='192.168.1.155',port=3306,user='root',passwd='test123',database='test',charset='utf8')

????cs = conn.cursor()

????for num in range(0, 100):

????????try:

????????????sql = "INSERT INTO rcs_up_message_info(merh_id,app_id,phone,msg_type,msg_content,send_time,create_time) VALUES('1','1','18811110000','2','这是一条测试文本','2021-11-05 18:54:50','2021-11-05 18:54:50')"

????????????cs.execute(sql)

????????except Exception as e:

????????????return

????conn.commit()

????cs.close()

????conn.close()

????print('完成任务！')

add_test_up_message