人工智能之Python18 用python3连接mysql数据库
2018-03-06 11:33
477 查看
任何一种编程语言都有数据库交互能力,python也不例外。
Python3 使用 PyMySQL 连接数据库,并实现简单的增删改查。
如下图:
Python3 使用 PyMySQL 连接数据库,并实现简单的增删改查。
关于PyMysql
PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库,Python2中则使用mysqldb。安装PyMysql
PyMysql的安装有多种方式,我这里用的ide时pycharm,解释器是anacanda,所以直接界面点击安装如下图:
连接数据库并建表
新建create_table.pyimport pymysql db_connect = pymysql.connect("192.168.216.129","root","root@mariadb","ai") cursor = db_connect.cursor() cursor.execute("DROP TABLE IF EXISTS t_ai_test") print(cursor.rowcount) sql_create_table = """CREATE TABLE t_ai_test ( FIRST_NAME CHAR(20) NOT NULL, LAST_NAME CHAR(20), AGE INT, SEX CHAR(1), INCOME FLOAT )""" cursor.execute(sql_create_table) db_connect.commit() print(cursor.rowcount) cursor.close() db_connect.close() # 执行完之后发现数据库多了一张表
插入一条数据
insert.pyimport pymysql db_connect = pymysql.connect("192.168.216.129","root","root@mariadb","ai") cursor = db_connect.cursor() sql_insert_table = """insert into t_ai_test (FIRST_NAME,LAST_NAME,AGE,SEX,INCOME) values ('he','shiyuan',18,'1',20000)""" try: cursor.execute(sql_insert_table) db_connect.commit() print(cursor.rowcount) except Exception as e: db_connect.rollback() print("insert sql捕获到异常") raise e cursor.close() db_connect.close() # 查询数据库发现数据已经插入成功
修改
update.pyimport pymysql db_connect = pymysql.connect("192.168.216.129","root","root@mariadb","ai") cursor = db_connect.cursor() sql_insert_table = """update t_ai_test set INCOME = 30000 where FIRST_NAME = 'he' and LAST_NAME = 'shiyuan'""" try: cursor.execute(sql_insert_table) db_connect.commit() print(cursor.rowcount) except Exception as e: db_connect.rollback() print("insert sql捕获到异常") raise e cursor.close() db_connect.close()
查询
select.pyimport pymysql db_connect = pymysql.connect("192.168.216.129","root","root@mariadb","ai") cursor = db_connect.cursor() sql_select_table = """select * from t_ai_test where FIRST_NAME = 'he' and LAST_NAME = 'shiyuan'""" try: cursor.execute(sql_select_table) data = cursor.fetchall() db_connect.commit() if(len(data) > 0): print(data) else: print("no data") except Exception as e: db_connect.rollback() print("insert sql捕获到异常") raise e cursor.close() db_connect.close()
删除
delete.pyimport pymysql db_connect = pymysql.connect("192.168.216.129","root","root@mariadb","ai") cursor = db_connect.cursor() sql_delete_table = """delete from t_ai_test where FIRST_NAME = 'he' and LAST_NAME = 'shiyuan'""" try: cursor.execute(sql_delete_table) data = cursor.fetchall() db_connect.commit() print(cursor.rowcount) except Exception as e: db_connect.rollback() print("delete sql捕获到异常") raise e cursor.close() db_connect.close()
总结
以上便是python3操作mysql数据库的增删改查操作。后续完善更新源码
python整合mysql相关文章推荐
- Python Web开发Django框架学习(十三)连接MySQL数据库
- python3.5连接mysql数据库
- Python连接mysql数据库的正确姿势
- python使用mysqldb连接mysql数据库
- python 连接MySQL数据库报错的解决办法
- 记录python连接mysql数据库:python安装MySQL_Python时出现is not a supported wheel on this platform.
- Mac下python连接mysql数据库
- Python连接mysql数据库
- Python3连接MySQL数据库
- Python之道--Python连接MYSQL数据库和发送邮件
- 第一次用python连接mysql数据库
- python连接mysql数据库
- Python3下Django连接Mysql数据库
- python3.5连接mysql数据库
- python 连接sql server、mysql数据库
- python3.4 使用pymysql 连接mysql数据库
- python django 连接mysql数据库
- 使用python多线程连接mysql数据库
- Python进阶(五十二)-Flask使用pymysql连接MySQL数据库
- python连接mysql数据库