python 操作mysql数据库
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了python 操作mysql数据库,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含1990字,纯文字阅读大概需要3分钟。
内容图文
![python 操作mysql数据库](/upload/InfoBanner/zyjiaocheng/870/cb85b7965d5b44f1a9f83d05a50cdb6b.jpg)
安装mysql模块
pip install PyMySQL
pip install sqlalchemy
操作mysql数据
#!/usr/bin/env python
# -*- coding: utf-8 -*-
# import cx_Oracle from sqlalchemy import create_engine from sqlalchemy.orm import sessionmaker import traceback class DB: """ 数据库操作 create_engine("dialect+driver://username:password@host:port/database") #初始化连接 dialect:数据库类型,包括sqlite,mysql,postgresql,oracle,mssql等 driver:指定连接数据库的API,如 psycopg2,pyodbc,cx_oracle,为可选关键字 """ engine = None def session(self): try: dbSession = sessionmaker(bind=self.engine) cursor = dbSession() except Exception as e : print('DataBase found errors: {0}'.format(e)) return cursor def query(self,sql): #执行查询语句 try: query = self.session() ret = query.execute(sql) data = ret.fetchall() return data except: print(traceback.format_exc()) print('查询数据异常') return [] def execute(self,sql): #执行单条语句 try: execute = self.session() ret = execute.execute(sql) execute.commit() execute.close() return 0 except: print('执行[%s]失败'%sql) execute.rollback() execute.close() return -1 def execute_many(self,SqlList): #执行多条sql try: execute = self.session() for sql in SqlList: ret = execute.execute(sql) execute.commit() execute.close() return 0 except: print('执行[%s]失败'%sql) execute.rollback() execute.close() return -1 class MysqlDB(DB): """mysql数据库""" def __init__(self,host,user,passwd,database,port=3306): url = f'mysql+pymysql://{username}:{passwd}@{host}:{port}/{database}?charset=utf8'
self.engine = create_engine(url,encoding='utf8',pool_size=100, pool_recycle=3600, echo=False) class OracleDB(DB): """Oracle数据库""" def __init__(self,host,username,passwd,dsn,port=1521): url = f'oracle+cx_oracle://{username}:{passwd}@{host}:{port}/{dsn}?charset=utf8'
self.engine = create_engine(url,encoding='utf8',pool_size=100, pool_recycle=3600, echo=False) if __name__ == '__main__': mysql = MysqlDB('39.101.187.225','boye','boyecom@126','crawler') ret = mysql.query('show tables') query =mysql.query("select * from test"); print(ret) print(query)
内容总结
以上是互联网集市为您收集整理的python 操作mysql数据库全部内容,希望文章能够帮你解决python 操作mysql数据库所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。