स्काला में रिलेशनल डेटाबेस के साथ काम करना

शुभ दोपहर, आज मैं आपको बताना चाहूंगा कि हमारी टीम डेटाबेस के साथ कैसे काम करती है। हमारी कंपनी मुख्य रूप से ओरेकल का उपयोग करती है और हमारी टीम में बहुत सारे लोग हैं जो इसे अच्छी तरह से पका सकते हैं। प्रारंभ में, हम इसकी क्षमताओं तक पूरी पहुँच प्राप्त करना चाहते थे: पदानुक्रमित प्रश्न, विश्लेषणात्मक कार्य, ऑब्जेक्ट और संग्रह को क्वेरी पैरामीटर के रूप में स्थानांतरित करना, और, शायद, अगर कोई अन्य तरीका नहीं है - संकेत। हमारा मॉडल बहुत जटिल नहीं है, इसलिए हमने जानबूझकर ORM को छोड़ दिया।

हमने Apache DbUtils को एक आधार के रूप में लिया और स्काला पर इसके लिए एक साधारण आवरण बनाया। नीचे मैं आपको बताऊंगा कि कैसे स्कैला की क्षमताओं, विशेष रूप से इसके नवीनतम संस्करण 2.10 ने डेटाबेस के साथ काम को आसान बनाने में मदद की।

और अंत तक पढ़ने वाले जिज्ञासु पाठक आश्चर्यचकित होंगे।

कनेक्शन के साथ काम करें

जैसा कि आप जानते हैं, जब एक डेटाबेस के साथ काम करते हैं, जब तक आपके पास एक बहुत ही सरल परियोजना नहीं होती है, तो आपको कनेक्शन का पुन: उपयोग करने की आवश्यकता होती है। इसके लिए पूल का उपयोग किया जाता है (DBCP, c3po आदि देखें)। यदि आप पूल का उपयोग माथे पर करते हैं, तो जल्दी या बाद में कोई व्यक्ति कनेक्शन पूल देना भूल जाएगा। आमतौर पर, परीक्षणों और डिबगिंग के दौरान, ऐसी समस्याएं दिखाई नहीं देती हैं, कभी-कभी वे प्रतिगमन के माध्यम से भी जा सकते हैं और एक लड़ाकू वातावरण में स्थानांतरित हो सकते हैं, जहां वे तुरंत खुद को नहीं पाएंगे।

यह सुनिश्चित करने के लिए कि कनेक्शन हमेशा पूल में रहेगा, आपको इसे स्वचालित रूप से बंद करना होगा। यह सुविधाजनक है यदि कनेक्शन सीमित दायरे में जारी किया जाता है, और इसे छोड़ने पर बंद हो जाता है:

def execute[R](operation: Connection => R): R = { val connection = driver.getConnection() try { operation(connection) } finally { connection.close() } } 

यह स्पष्ट है कि यह कोड बहुत योजनाबद्ध है, इसमें ऑटो कमिट और लेन-देन रोलबैक के साथ कोई काम नहीं है, लेकिन यह सामान्य विचार को प्रभावित नहीं करता है। आप डेटाबेस के साथ काम निम्नानुसार कर सकते हैं:

 database.execute { connection => database.query("select ? from dual", Seq(1))(connection) } 

या बस

 database execute query ("select ? from dual", Seq(1)) 

यहाँ स्काला पहले से ही बहुत मदद करता है, क्योंकि जावा में, आपको एक राक्षसी अनाम वर्ग उत्पन्न करने की आवश्यकता है जो एक समान दृष्टिकोण का उपयोग करने की सभी इच्छा को मारता है।

आयात

एक डेटाबेस पर अमूर्त के रूप में इस तरह के एक सामान्य घटक के लिए, मैं बहुत से अलग कबाड़ आयात नहीं करना चाहता। दुर्भाग्य से, अब आयात आयात करने के लिए कोई सामान्य उपाय नहीं है। गुगली वाली आखिरी चीज है इम्पोर्ट ऑब्जेक्ट पर बहस। हाल तक तक, डेटाबेस के साथ काम करने के लिए सभी सुविधाओं का उपयोग करने के लिए, मुझे तीन आयात लिखने पड़े।

हम एक पैकेज ऑब्जेक्ट बनाकर आयात की संख्या को अनुकूलित करने में कामयाब रहे, जहां सभी सार्वजनिक घोषणाएं चलती थीं: कार्य, निहित रूपांतरण और स्थिरांक। कक्षाएं एक ही पैकेज में रहीं। परिणामस्वरूप, डेटाबेस के साथ काम करने के लिए आवश्यक सभी घोषणाओं को आयात करने के लिए, आपको लिखना होगा:

  import ru.tcsbank.utils.database._ 

डेटाबेस के साथ काम करना आसान बनाने के लिए, जैसे `डेटाबेस एग्जीक्यूट क्वेरी (" सेलेक्ट? डुअल ", सीक (1)), हमारे सहयोगी ने मौजूदा स्कोप के लिए डेटाबेस ऑब्जेक्ट इंस्टेंस की सामग्री को आयात करने का सुझाव दिया:

  import database._ 

स्ट्रिंग इंटरपोलेशन SQL के लिए

डेटाबेस के साथ काम करते समय पासिंग पैरामीटर हमेशा एक बड़ा सिरदर्द होता है: नवागंतुक मापदंडों को प्रश्नों में चिपकाने की कोशिश करते हैं, जिससे सुरक्षा छेद और एक डीबीए सिरदर्द पैदा होता है, सामान्य डेवलपर्स आवश्यक संख्या में मापदंडों को पारित करने या आदेश को भ्रमित करने के लिए भूल जाते हैं।

जैसे ही स्कैला 2.10 सामने आया मैंने फीचर्स की सूची पर ध्यान दिया। पहली नज़र में, मैं वास्तव में लाइन प्रक्षेप की तरह नहीं था: "उन्होंने PHP से कुछ कचरा खींचा, अब उसी के लिए वे अलग-अलग वाक्यविन्यास का उपयोग करेंगे, और लाइनों से पहले एक मैजिक` s 'भी होगा! "मैंने सोचा। कुछ समय बाद, मैंने डेटाबेस के लिए अनुरोध लिखा और सभी मापदंडों को सही क्रम में व्यवस्थित करने का प्रयास किया। और फिर मुझे इंटरपोल याद आ गया! "यहाँ यह है!" मेरे सिर के माध्यम से चमकती है, मुझे एक `sql` इंटरपोलर लिखना था जो मापदंडों को लागू करेगा, यह स्पष्ट है! 10 मिनट के बाद, मुझे इंटरनेट पर पहले ही सही इंटरपोलर मिल गया: http://gist.github.com/mnesarco/4515575 ।

इसे समाप्त करना अभी भी आवश्यक था ताकि यह सहमति, बैच अनुरोध और मापदंडों का समर्थन करे, लेकिन यह एक बहुत ही महत्वपूर्ण कदम था, अब हमारे अनुरोधों पर एक नया नज़र है:

 database execute query ( sql"select ${magic} from dual where 1=${one}" ) 

मल्टी-लाइन एसक्यूएल प्रश्नों के लिए, कॉनटेक्स्ट की तुलना में मल्टी-लाइन स्ट्रिंग्स (मल्टी-लाइन स्ट्रिंग्स ?: -एस) के लिए सिंटैक्स का उपयोग करना बेहतर होता है, क्योंकि कोड क्लीनर और अपने पसंदीदा एसक्यूएल संपादक की नकल करना आसान है।

 database execute call ( sql"""begin pack.proc(param1 => ${value1}, param2 => ${value2}); end;""" ) 

मेरे लिए सबसे बड़ा आश्चर्य यह था कि इंटेलीज आईडीईए को किसी तरह अपने आप पता चल गया था कि मेरे स्वयं के प्रक्षेप के अंदर का पाठ एसक्यूएल था और इसे सही ढंग से उजागर करना शुरू कर दिया, जो पहले से ही शांत से परे था।

ठीक है, अब मेरे पुस्तकालय दलाल!

यह कोई रहस्य नहीं है कि java.util.ResultSet बहुत निम्न-स्तरीय API प्रदान करता है। मौलिक रूप से, एक परिणाम केवल एक बार पढ़ा जा सकता है, और इसकी पंक्तियाँ और स्तंभ बहुत ही असंबंधित बातें हैं। इसलिए, हमारे पास ResultSet से पढ़ने के लिए दो सार हैं - इन सभी से एक निश्चित प्रकार का एक संग्रह प्राप्त करने के लिए, साथ ही इसके स्तंभ के मूल्य को पढ़ने और लपेटने के लिए।

पहला अमूर्त, जो कि रिजल्टसेट से एक फ़ंक्शन है, सभी प्रकार के मल्टी मैप्स, सेट्स, सूचियों और विकल्पों को बना सकता है, और कर्सर को सही ढंग से नियंत्रित करने, कुंजियों द्वारा डेटा को समूहीकृत करने और दूसरे स्तर के लिए विशिष्ट मानों के निर्माण का प्रतिनिधित्व करने के लिए जिम्मेदार है।

दूसरा अमूर्त एक अंतर्निहित रूपांतरण है जो `ResultSet` की क्षमताओं का विस्तार करता है, यह तालिका की वर्तमान पंक्ति के साथ काम करता है और आपको हमारी कंपनी के लिए मूल डोमेन ऑब्जेक्ट पढ़ने की अनुमति देता है: Id, Time, और यह भी जानता है कि क्लास क्लास के उदाहरण कैसे बनाएं, लेकिन सबसे मूल्यवान बात यह है कि यह जानते हैं कि उन विकल्पों में कैसे लपेटें जहां मूल्य वास्तव में मौजूद नहीं हो सकते हैं।

परिणामस्वरूप, हम स्वतंत्र रूप से लिख सकते हैं:

 resultSet.getOptionalString("NICKNAME") resultSet.getId[User]("USER_ID") resultSet.getOptionalId[Account]("ACCOUNT_ID") 

पूरे डेटाबेस कॉल की तरह लग सकता है

 database execute query ( sql"select id, nickname from user", toSetMultiMap(_.getId[User]("id"), _.getOptionalString("nickname"))) 

स्रोत कोड

जैसा कि आप जानते हैं, हम वित्त के क्षेत्र में एक वाणिज्यिक कंपनी हैं और हमारे कोड को साझा नहीं कर सकते हैं। लेकिन आज हम एक नए गुण में खुद को आजमाते हैं। स्रोत कोड, जिसका उदाहरण मैंने दिया, अच्छी परिवर्धन के साथ, GITHub पर MIT लाइसेंस के तहत उपलब्ध है, अर्थात, आप इसे अपनी परियोजनाओं में उपयोग कर सकते हैं और अपने लिए अनुकूलित कर सकते हैं!

हमारे पास एक रिपॉजिटरी https://github.com/TinkoffCreditSystems भी है, जहां हम मूल समाधानों को जारी रखने की कोशिश करेंगे। हम दिलचस्प टिप्पणियों और पुल अनुरोधों के लिए आशा करते हैं।

निष्कर्ष

और निष्कर्ष कुछ इस तरह है: ORM का उपयोग करना आवश्यक नहीं है ताकि संबंधपरक डेटाबेस के साथ काम करना आसान और सरल हो। और इसके लिए पर्याप्त कोड की केवल 400 लाइनें हैं।

केवल एक चीज जो शायद मुझे कुतर रही है, वह यह है कि जेडीबीसी के माध्यम से काम अभी भी सिंक्रोनाइज़ होता है और थ्रेड्स ब्लॉक करता है। यदि आप पूरी तरह से प्रतिक्रियाशील बन सकते हैं यदि आप पूरी तरह से एक अतुल्यकालिक ड्राइवर वाले डेटाबेस पर स्विच करते हैं। यह भविष्य के लिए एक योग्य लक्ष्य है।

और आपको क्या लगता है कि डेटाबेस के साथ काम करने में और सुधार किया जा सकता है।