कैसे MySQL

Question

में SQLAlchemy कनेक्शन बंद करने के लिए यह एक नमूना कोड मैं चलाना चाहते है:

for i in range(1,2000): 
    db = create_engine('mysql://root@localhost/test_database') 
    conn = db.connect() 
    #some simple data operations 
    conn.close() 
    db.dispose() 

वहाँ MySQL से "बहुत अधिक कनेक्शन" त्रुटियों के बिना इस चलाने का कोई तरीका है? मुझे पहले से ही पता है कि मैं कनेक्शन को अन्यथा संभाल सकता हूं या कनेक्शन पूल कर सकता हूं। मैं सिर्फ यह समझना चाहता हूं कि sqlalchemy से कनेक्शन को सही तरीके से कैसे बंद करें। अग्रिम धन्यवाद!

Answer 1

यहाँ कैसे सही ढंग से कि कोड लिखने के लिए है:

db = create_engine('mysql://root@localhost/test_database') 
for i in range(1,2000): 
    conn = db.connect() 
    #some simple data operations 
    conn.close() 
db.dispose() 

है, Engine कनेक्शन के लिए एक कारखाने के साथ ही कनेक्शन की एक पूल, नहीं कनेक्शन ही है। जब आप conn.close() कहते हैं, तो कनेक्शन इंजन के भीतर कनेक्शन पूल पर वापस आ गया है, वास्तव में बंद नहीं है।

आप कनेक्शन वास्तव में बंद करने के लिए हो सकता है, किया जाता है कि, जमा नहीं, NullPool के माध्यम से पूलिंग को अक्षम चाहते हैं:

from sqlalchemy.pool import NullPool 
db = create_engine('mysql://root@localhost/test_database', poolclass=NullPool) 

ऊपर Engine विन्यास के साथ, conn.close() की प्रत्येक कॉल अंतर्निहित DBAPI कनेक्शन बंद हो जाएगा।

आप वास्तव में प्रत्येक कॉल पर अलग डेटाबेस से कनेक्ट करना चाहते हैं OTOH, कि अपने hardcoded "localhost/test_database" सिर्फ एक उदाहरण है और आप वास्तव में विभिन्न डेटाबेस के बहुत सारे है, तो dispose() का उपयोग कर दृष्टिकोण ठीक है है; यह पूल से चेक आउट नहीं होने वाले प्रत्येक कनेक्शन को बंद कर देगा।

उपरोक्त सभी मामलों में, महत्वपूर्ण बात यह है कि Connection ऑब्जेक्ट close() के माध्यम से बंद है। यदि आप किसी भी प्रकार के "कनेक्शन रहित" निष्पादन का उपयोग कर रहे हैं, तो engine.execute() या statement.execute() है, ResultProxy उस निष्पादन कॉल से लौटाई गई वस्तु पूरी तरह से पढ़ी जानी चाहिए, या अन्यथा close() के माध्यम से स्पष्ट रूप से बंद होना चाहिए। एक Connection या ResultProxy जो अभी भी खुला है, हर अंतिम कनेक्शन को बंद करने से NullPool या dispose() दृष्टिकोणों को प्रतिबंधित करेगा।

Answer 2

किसी असंबंधित समस्या के लिए डेटाबेस से डिस्कनेक्ट करने के लिए समाधान निकालने का प्रयास करने की कोशिश की गई है (फोर्किंग से पहले डिस्कनेक्ट होना चाहिए)।

आपको कनेक्शन पूल से कनेक्शन invalidate की आवश्यकता है।

अपने उदाहरण में:

for i in range(1,2000): 
    db = create_engine('mysql://root@localhost/test_database') 
    conn = db.connect() 
    # some simple data operations 
    # session.close() if needed 
    conn.invalidate() 
    db.dispose()