Skip to main content

A very simple asynchronous wrapper that allows you to get access to the Oracle database in asyncio programs.

Project description

cx_Oracle_async

fury licence pyversions Publish Build Docs Visitors

A very simple asynchronous wrapper that allows you to get access to the Oracle database in asyncio programs.

Easy to use , buy may not the best practice for efficiency concern.

Requirements

  • cx_Oracle >= 8.1.0 (Take into consideration that author of cx_Oracle said he's trying to implement asyncio support , APIs maybe change in future version. Switch to 8.1.0 if there's something wrong makes it not gonna work.)
  • ThreadPoolExecutorPlus >= 0.2.0

Install

pip install cx_Oracle_async

Feature

  • Nearly all the same as aiomysql in asynchronous operational approach , with limited cx_Oracle feature support.
  • No automaticly date format transition built-in.
  • AQ feature added , check docs here for further information.
  • You can modify some of the connection properties simply like you're using cx_Oracle.
  • You can do basic insert / select / delete etc.
  • If you're connecting to database which is on a different machine from python process , you need to install oracle client module in order to use this library. Check cx-Oracle's installation guide for further information.

Documentation

https://cx_oracle_async.readthedocs.io

Performance

query type asynchronous multithreading synchronous multithreading synchronous single thread
fast single line query 6259.80 q/s 28906.93 q/s 14805.61 q/s
single line insertion 1341.88 q/s 1898 q/s 1685.17 q/s

/* Test platform: */
AMD Ryzen 3700x
Windows 10 LTSC
Oracle 19c
You can find performance test codes here.

Examples

Before running examples , make sure you've already installed a Oracle Client on your machine.

# basic_usages.py
import asyncio
import cx_Oracle_async

async def main():
    oracle_pool = await cx_Oracle_async.create_pool(
        host='localhost', 
        port='1521',
        user='user', 
        password='password',
        service_name='orcl', 
        min = 2,
        max = 4,
    )

    async with oracle_pool.acquire() as connection:
        async with connection.cursor() as cursor:
            await cursor.execute("SELECT * FROM V$SESSION")
            print(await cursor.fetchall())

    await oracle_pool.close()

if __name__ == '__main__':
    asyncio.run(main())

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

cx_Oracle_async-0.3.3.tar.gz (8.8 kB view details)

Uploaded Source

Built Distribution

cx_Oracle_async-0.3.3-py3-none-any.whl (11.1 kB view details)

Uploaded Python 3

File details

Details for the file cx_Oracle_async-0.3.3.tar.gz.

File metadata

  • Download URL: cx_Oracle_async-0.3.3.tar.gz
  • Upload date:
  • Size: 8.8 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/4.0.0 CPython/3.8.12

File hashes

Hashes for cx_Oracle_async-0.3.3.tar.gz
Algorithm Hash digest
SHA256 12515563210d52e2d58c3df39a708eef4e3bd21d856c54635821bca43d870b1f
MD5 151a0df44da306eb8dd7cdc1f617e267
BLAKE2b-256 d187fe75e196c5570749ae228b6b85b78b0d887d412e54c504642f46f4eef857

See more details on using hashes here.

File details

Details for the file cx_Oracle_async-0.3.3-py3-none-any.whl.

File metadata

File hashes

Hashes for cx_Oracle_async-0.3.3-py3-none-any.whl
Algorithm Hash digest
SHA256 1eee2a2405cb6700da4efc094b0f3c5217afc406bc4e9404f794f2c0bd713999
MD5 b5b5fd0f72f985918e1ccd380529a47e
BLAKE2b-256 d0ef4c7767c9917e5d25ed6c780ee82a251ac83a569d725310e7db0bcde5a064

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page