Oracle-ga ulanish

2.1 Ulanishni birlashtirish

Quyidagi kodni ko'rib chiqing connect_pool.py:

import cx_Oracle

import iplari

import db_config

hovuz = cx_Oracle. SessionPool (db_config.user, db_config.pw, db_config.dsn,

min = 2, maksimal = 5, o'sish = 1, tishli = rost,

getmode = cx_Oracle.SPOOL_ATTRVAL_WAIT)
def Query():

con = hovuz. olish ()

cur = con.cursor()

diapazondagi i uchun(4):

cur.execute("dualdan myseq.nextval-ni tanlang")

seqval, = cur.fetchone()

print("Thread", threading.current_thread().name, "olish sequence=", seqval)
thread1 = threading.Thread(name='#1', maqsad=so'rov)

thread1.start()

thread2 = threading.Thread(name='#2', maqsad=so'rov)

thread2.start()

thread1.join()

thread2.join()

chop etish ("Hammasi tugadi!")

SessionPool()Funktsiya foydalanuvchi uchun Oracle ulanishlar bir hovuz yaratadi. Hovuzdagi ulanishlardan cx_Oracle tomonidan qo'ng'iroq qilish orqali foydalanish mumkin pool.acquire(). Hovuzning dastlabki hajmi - 2 ta ulanish. Maksimal o'lcham - 5 ta ulanish. Hovuz o'sishi kerak bo'lganda, bir vaqtning o'zida 1 ta yangi ulanish yaratiladi. Ulanishlar endi ishlatilmaganda basseyn minimal hajmi 2 ga qisqarishi mumkin.

def Query():Satr, har bir ip bilan atalgan bir usuli yaratadi.

Usuli, pool.acquire()(foydalanishda allaqachon uzoq sifatida kamida 5 kabi) qo'ng'iroq pulidan bir aloqasi oladi. Ushbu ulanish ketma-ketlikni so'rash uchun 4 ta iterasyon döngüsünde ishlatiladi myseq. Usul oxirida cx_Oracle kursorni avtomatik ravishda yopadi va ulanishni qayta foydalanish uchun hovuzga qaytaradi.

seqval, = cur.fetchone()Liniyasi bir satr keltiradi va o'zgaruvchilar natija shamlardan mavjud yagona qiymatini qo'yadi seqval. seqvalVergulsiz qiymat " (1,)" kabi kortej bo'ladi .

Ikkita ip yaratiladi, ularning har biri Query()usulni chaqiradi .

Buyruqlar terminalida quyidagilarni bajaring: