pythonmysql使用教程(Python异步操作MySQL示例使用aiomysql)
类别:脚本大全 浏览量:1059
时间:2021-09-29 03:09:16 pythonmysql使用教程
Python异步操作MySQL示例使用aiomysql本文实例讲述了python异步操作mysql。分享给大家供大家参考,具体如下:
安装aiomysql
依赖
- python3.4+
- asyncio
- pymysql
安装
|
pip install aiomysql |
应用
基本的异步连接connection
|
import asyncio from aiomysql import create_pool loop = asyncio.get_event_loop() async def go(): async with create_pool(host = '127.0.0.1' , port = 3306 , user = 'root' , password = '', db = 'mysql' , loop = loop) as pool: async with pool.get() as conn: async with conn.cursor() as cur: await cur.execute( "select 42;" ) value = await cur.fetchone() print (value) loop.run_until_complete(go()) |
异步的连接池 pool
|
import asyncio import aiomysql async def test_example(loop): pool = await aiomysql.create_pool(host = '127.0.0.1' , port = 3306 , user = 'root' , password = '', db = 'mysql' , loop = loop) async with pool.acquire() as conn: async with conn.cursor() as cur: await cur.execute( "select 42;" ) print (cur.description) (r,) = await cur.fetchone() assert r = = 42 pool.close() await pool.wait_closed() loop = asyncio.get_event_loop() loop.run_until_complete(test_example(loop)) |
对象关系映射sqlalchemy - object relationship mapping
可以随意定义表结构,轻松调用查询、插入等操作方法。
|
import asyncio import sqlalchemy as sa from aiomysql.sa import create_engine metadata = sa.metadata() tbl = sa.table( 'tbl' , metadata, sa.column( 'id' , sa.integer, primary_key = true), sa.column( 'val' , sa.string( 255 ))) async def go(loop): engine = await create_engine(user = 'root' , db = 'test_pymysql' , host = '127.0.0.1' , password = '', loop = loop) async with engine.acquire() as conn: await conn.execute(tbl.insert().values(val = 'abc' )) await conn.execute(tbl.insert().values(val = 'xyz' )) async for row in conn.execute(tbl.select()): print (row. id , row.val) engine.close() await engine.wait_closed() loop = asyncio.get_event_loop() loop.run_until_complete(go(loop)) |
希望本文所述对大家python程序设计有所帮助。
原文链接:https://blog.csdn.net/ydyang1126/article/details/78226701
您可能感兴趣
- python编程加密解密(python实现AES加密解密)
- python使用aes加密解密(python实现AES和RSA加解密的方法)
- python查找含特定字符的字符串(Python实现查找字符串数组最长公共前缀示例)
- python 绕过密码(一小段Python代码,破解加密zip文件的密码)
- python 微信二维码接口(python实现微信防撤回神器)
- python函数操作大全(Python的高阶函数用法实例分析)
- python里字典常用方法(Python使用字典的嵌套功能详解)
- 如何用python爬取最新电影(使用python实现抓取腾讯视频所有电影的爬虫)
- python抽奖转盘代码(详解python--模拟轮盘抽奖游戏)
- 百度免费翻译接口(基于python实现百度翻译功能)
- python编程将一个三位数反序输出(python实现整数的二进制循环移位)
- python csv文件读取方法(对python读取zip压缩文件里面的csv数据实例详解)
- python入门练习网页(详解python项目实战:模拟登陆CSDN)
- python协程结果(深入浅析python 协程与go协程的区别)
- python中的isi(深入浅析Python 中 is 语法带来的误解)
- python正则表达式入门(Python正则表达式实现简易计算器功能示例)
- 红色代表什么(红色代表什么情感和含义)
- 高中数学题(高中数学题型总结及解题方法)
- 冰岛旅游攻略(冰岛旅游攻略及花费)
- 为什么现在年轻人越来越喜欢买衣服(为什么现在年轻人越来越喜欢买衣服穿)
- 怎么做好SEO(怎么做好seo内容优化)
- 冬季钓鱼子线用 长 还是 短(冬季钓鱼子线用)
热门推荐
- dedecms怎样查看网页源文件(dedecms批量更新静态时提示:没有该栏目数据 可能缓存的解决方法)
- centos7.5安装mysql教程(CentOS8下MySQL 8.0安装部署的方法)
- canvas时钟代码(canvas实现烟花的示例代码)
- pythonmath库引入方法(python使用thrift教程的方法示例)
- vnc连接linux黑屏(阿里云服务器VNC无法连接及黑屏的原因)
- mysql索引失效的几种情况(Mysql 5.6 "隐式转换"导致的索引失效和数据不准确的问题)
- mssql 存储过程查询语句(MSSQL分页存储过程完整示例支持多表分页存储)
- linq 数据类型转换
- laravel框架的高级知识点(laravel配置Redis多个库的实现方法)
- php提供哪些函数来避免sql的注入(PHP与SQL语句写一句话木马总结)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9