zoukankan      html  css  js  c++  java
  • aiomysql inserting operation failed !

    emotions:

    those days,i am using aiomysql(python3.5) to acess my database .But a 'strange' problem make me trouble more times.The problem is i can't insert data into my database table using aiomysql's cursor.execute(**) method. Fortunately,i sovled it after refering aiomysq's manual.

    plateform:

    1.ubuntu14.04
    2.python3.5

    error code:

    import aiomysql 
    import asyncio
    
    loop=asyncio.get_event_loop()
    @asyncio.coroutine
    def insert(loop):
            pl=yield from aiomysql.create_pool(host='127.0.0.1',user='root',password='xxxxx',db='blog',loop=loop,port=3306)
            with (yield from pl) as con:
                    cursor=yield from con.cursor()
                    yield from cursor.execute('insert into users(`user_name`,`email`,`password`) values("coder","1xxxxxb@gmail.com","FHEUIE@#@@##JNDJA")')
                    yield from cursor.close()
                    con.commit()
            pl.close()
            yield from pl.wait_closed()
    
    loop.run_until_complete(insert(loop))
    loop.run_forever()
    

    I run the above code many times,but there is still no data in my database table.

    solution:

    After refering aiomysql's manual,I found 'aiomysql.commit' method is coroutine,that's a critical point.just rewrite 'con.commit()' to 'yield from con.commit()',the problem is sovled!

    correct code:

    import aiomysql 
    import asyncio
    
    loop=asyncio.get_event_loop()
    @asyncio.coroutine
    def insert(loop):
            pl=yield from aiomysql.create_pool(host='127.0.0.1',user='root',password='xxxxx',db='blog',loop=loop,port=3306)
            with (yield from pl) as con:
                    cursor=yield from con.cursor()
                    yield from cursor.execute('insert into users(`user_name`,`email`,`password`) values("coder","1xxxxxb@gmail.com","FHEUIE@#@@##JNDJA")')
                    yield from cursor.close()
                    yield from con.commit()
            pl.close()
            yield from pl.wait_closed()
    
    loop.run_until_complete(insert(loop))
    loop.run_forever()
    
  • 相关阅读:
    Lakehouse: 统一数据仓库和高级分析的新一代开放平台
    mac进入恢复模式,关闭/启动系统完整性(SIP)
    多个xcode版本并存,切换xcode版本
    pod执行指定缓存目录,多版本pod执行缓存目录被清问题
    java特殊处理String.format中的%,使用%做一次转义
    html div设置占屏幕占比高度(使用vh)
    vue+leaflet 地图相关
    vue 集成天地图
    vue iframe嵌套外部网页
    Fabric.js
  • 原文地址:https://www.cnblogs.com/whereareyoufrom/p/5269010.html
Copyright © 2011-2022 走看看