Node.js और Oracle डेटाबेस के साथ REST API बनाना। भाग २

भाग 2: एक रीस्ट एपीआई बनाना: डेटाबेस मूल बातें

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

चल रहा है कनेक्शन पूल

क्योंकि नोड- oracledb OCI क्लाइंट पुस्तकालयों के शीर्ष पर बनाया गया है, इसलिए इसमें OCI पूल बनाने के लिए समर्थन है जो क्लाइंट-साइड हैं और उत्कृष्ट प्रदर्शन विशेषताओं वाले हैं। एक कनेक्शन पूल बनाने के लिए, एक नई कॉन्फ़िगरेशन फ़ाइल बनाकर शुरू करें जिसे डेटाबेस निर्देशिका में कहा जाता है । फ़ाइल में निम्न कोड को कॉपी और पेस्ट करें और परिवर्तनों को सहेजें।

module.exports = { hrPool: { user: process.env.HR_USER, password: process.env.HR_PASSWORD, connectString: process.env.HR_CONNECTIONSTRING, poolMin: 10, poolMax: 10, poolIncrement: 0 } }; 

जैसा कि config / webserver.js फ़ाइल के साथ है, यह फ़ाइल आपको पर्यावरण चर का उपयोग करके कुछ गुण सेट करने की अनुमति देती है। विभिन्न प्रकार के वातावरण में एप्लिकेशन को तैनात करते समय पर्यावरण चर का उपयोग लचीलापन प्रदान करता है और स्रोत कोड के बाहर पासवर्ड और अन्य संवेदनशील जानकारी को बचाने में मदद करता है। आवश्यक वातावरण चर सेट करने के लिए टर्मिनल से निम्नलिखित कमांड चलाएँ और सुनिश्चित करें कि वे भविष्य के टर्मिनल सत्रों में उपलब्ध हैं।

 echo "export HR_USER=hr" >> ~/.bashrc echo "export HR_PASSWORD=oracle" >> ~/.bashrc echo "export HR_CONNECTIONSTRING=0.0.0.0/orcl" >> ~/.bashrc source ~/.bashrc 

आप देख सकते हैं कि पूलमाइन और पूलमैक्स एक ही थे और वह पूलइन्क्रिमेंट ०. पर सेट था। यह एक निश्चित आकार का पूल बनाएगा जिसके लिए कम प्रबंधन संसाधनों की आवश्यकता होती है - पूल के लिए एक अच्छा विचार जो लगातार उपयोग प्राप्त करता है।

हालाँकि, Node.js को अक्सर "एकल-थ्रेडेड" के रूप में वर्णित किया जाता है, इसमें कुछ संचालन के लिए एक थ्रेड पूल उपलब्ध होता है जो अन्यथा जावास्क्रिप्ट कोड को चलाने वाले मुख्य धागे को अवरुद्ध करेगा। इस थ्रेड पूल का उपयोग नोड-ऑर्केल्ड द्वारा अपने सभी अतुल्यकालिक संचालन करने के लिए किया जाता है, जैसे कि कनेक्शन प्राप्त करना और SQL और PL / SQL कोड को निष्पादित करना। हालाँकि, डिफ़ॉल्ट थ्रेड पूल का आकार 4. है। यदि आप चाहते हैं कि पूल में सभी 10 कनेक्शन एक साथ काम करें, तो आपको तदनुसार थ्रेड्स की संख्या बढ़ाने की आवश्यकता है।

UV_THREADPOOL_SIZE पर्यावरण चर का उपयोग थ्रेड पूल के आकार को समायोजित करने के लिए किया जा सकता है। UV_THREADPOOL_SIZE को Node.js एप्लिकेशन या आंतरिक रूप से चलाने से पहले सेट किया जा सकता है, लेकिन थ्रेड पूल का उपयोग करके पहली कॉल किए जाने से पहले इसे सेट किया जाना चाहिए। यह इस तथ्य के कारण है कि थ्रेड पूल इसके पहले उपयोग पर बनाया गया है और इसके निर्माण के बाद, इसका आकार तय किया गया है। एप्लिकेशन की जड़ में index.js फ़ाइल खोलें और पहली पंक्ति (जिसमें वेब सर्वर मॉड्यूल शामिल है) के बाद निम्नलिखित लाइनें जोड़ें।

 // *** line that requires services/web-server.js is here *** const dbConfig = require('./config/database.js'); const defaultThreadPoolSize = 4; // Increase thread pool size by poolMax process.env.UV_THREADPOOL_SIZE = dbConfig.hrPool.poolMax + defaultThreadPoolSize; 

अब जब थ्रेड पूल का उपयुक्त आकार होता है, तो आप डेटाबेस मॉड्यूल पर जा सकते हैं। डेटाबेस नाम की सेवाओं निर्देशिका में एक नई फ़ाइल बनाएँ। निम्न कोड को इसमें कॉपी और पेस्ट करें और परिवर्तनों को सहेजें।

 const oracledb = require('oracledb'); const dbConfig = require('../config/database.js'); async function initialize() { const pool = await oracledb.createPool(dbConfig.hrPool); } module.exports.initialize = initialize; 

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

अब आपको सब कुछ कनेक्ट करने की आवश्यकता है ताकि वेब सर्वर के खुलने से पहले कनेक्शन पूल शुरू हो जाए। Index.js पर वापस जाएं और पंक्ति 1 के नीचे निम्न पंक्ति जोड़ें।

 // *** line that requires services/web-server.js is here *** const database = require('./services/database.js'); 

फिर वेब सर्वर शुरू करने वाले मौजूदा कोशिश ब्लॉक से पहले स्ट्रैटअप फ़ंक्शन के लिए निम्न प्रयास ब्लॉक को जोड़ें।

 try { console.log('Initializing database module'); await database.initialize(); } catch (err) { console.error(err); process.exit(1); // Non-zero failure code } // *** existing try block in startup here *** 

इस बिंदु पर, आप नोड- oracledb इंस्टॉल कर सकते हैं और कोड का परीक्षण कर सकते हैं। Hr_app निर्देशिका से किसी टर्मिनल में निम्न आदेश चलाएँ।

 npm install oracledb -s node . 

यदि आप संदेश देखते हैं कि डेटाबेस मॉड्यूल और वेब सर्वर चल रहे हैं, तो, बधाई - आपका कनेक्शन पूल अब काम कर रहा है!

शटडाउन कनेक्शन पूल

यदि आप अब एप्लिकेशन को बंद करते हैं (ctrl + c का उपयोग पहले की तरह), तो कनेक्शन पूल बंद होने से पहले Node.js प्रक्रिया को नष्ट कर दिया जाएगा। यद्यपि सभी संबंधित डेटाबेस प्रक्रियाओं को स्वचालित रूप से साफ किया जाना चाहिए, लेकिन Node.js. प्रक्रिया से बाहर निकलने से पहले कनेक्शन पूल को स्पष्ट रूप से बंद करना सबसे अच्छा है।

सेवाओं / database.js फ़ाइल पर लौटें, कोड की निम्नलिखित पंक्तियों को अंत तक जोड़ें, और अद्यतनों को सहेजें।

 // *** previous code above this line *** async function close() { await oracledb.getPool().close(); } module.exports.close = close; 

सम्‍मिलित फ़ंक्शन डिफ़ॉल्ट पूल को समकालिक रूप से प्राप्त करने के लिए oracledb.getPool () विधि का उपयोग करता है, और फिर इसे बंद करने के लिए पूल पर बंद विधि को कॉल करता है।

क्लोज़ फ़ंक्शन को सही समय पर कॉल करने के लिए, मौजूदा ट्रायल ब्लॉक के तुरंत बाद शटडाउन फ़ंक्शन के अंदर index.js फ़ाइल में कोड की निम्न पंक्तियों को जोड़ें, जो वेब सर्वर को रोकती हैं।

 // *** existing try-catch block in shutdown here *** try { console.log('Closing database module'); await database.close(); } catch (err) { console.log('Encountered error', e); err = err || e; } 

यदि आप एप्लिकेशन को फिर से शुरू और बंद करते हैं, तो आप देखेंगे कि वेब सर्वर को बंद करने के बाद डेटाबेस मॉड्यूल बंद है, लेकिन प्रक्रिया पूरी होने से पहले।

सरल CRUD संचालन को सरल बनाएं

नोड- oracledb का उपयोग करके SQL या PL / SQL कोड का निष्पादन आमतौर पर एक तीन-चरण प्रक्रिया है: कनेक्शन प्राप्त करें, कोड निष्पादित करें और फिर कनेक्शन जारी करें। यदि आप सब करना चाहते हैं तो निष्पादित करने के लिए एक कॉल करें (कोई मल्टी-स्टेप लेन-देन की आवश्यकता नहीं है), तो कनेक्शन प्राप्त करना और जारी करना मानक कोड की तरह लग सकता है। मैं एक फ़ंक्शन बनाना चाहता हूं जो एक कॉल में सभी तीन ऑपरेशन करता है। सेवाओं / database.js फ़ाइल पर लौटें, नीचे दिया गया कोड जोड़ें और परिवर्तनों को सहेजें।

 // *** previous code above this line *** function simpleExecute(statement, binds = [], opts = {}) { return new Promise(async (resolve, reject) => { let conn; opts.outFormat = oracledb.OBJECT; opts.autoCommit = true; try { conn = await oracledb.getConnection(); const result = await conn.execute(statement, binds, opts); resolve(result); } catch (err) { reject(err); } finally { if (conn) { // conn assignment worked, need to close try { await conn.close(); } catch (err) { console.log(err); } } } }); } module.exports.simpleExecute = simpleExecute; 

आमतौर पर, आप वेब सर्वर मॉड्यूल में डेटाबेस मॉड्यूल का उपयोग नहीं करेंगे, लेकिन यह सत्यापित करने के लिए इसे अभी जोड़ें कि यह सही ढंग से काम कर रहा है। सेवाओं / वेब-सर्वर.जेएस फ़ाइल खोलें और शीर्ष पर मौजूदा निरंतर घोषणाओं के तहत निम्न पंक्ति जोड़ें।

 // line that requires ../config/web-server.js here const database = require('./database.js'); 

फिर संपूर्ण App.get हैंडलर को बदलने के लिए निम्न कोड का उपयोग करें जो "हैलो वर्ल्ड" के साथ प्रतिक्रिया करता है। (सभी 3 लाइनें)।

 // *** line that adds morgan to app here *** app.get('/', async (req, res) => { const result = await database.simpleExecute('select user, systimestamp from dual'); const user = result.rows[0].USER; const date = result.rows[0].SYSTIMESTAMP; res.end(`DB user: ${user}\nDate: ${date}`); }); 

नया हैंडलर डेटाबेस उपयोगकर्ता के मौजूदा सिस्टम और सिस्टिमस्टैम्प के मूल्यों को पुनः प्राप्त करने के लिए डेटाबेस मॉड्यूल के simpleExecute फ़ंक्शन का उपयोग करता है। डायनामिक संदेश के साथ क्लाइंट को जवाब देने के लिए मानों का उपयोग टेम्पलेट शाब्दिक में किया जाता है।

एप्लिकेशन को फिर से लॉन्च करें और लोकलहोस्ट पर जाएं: 3000। आपको निम्न छवि जैसी कोई चीज देखनी चाहिए।



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