हम MySQL के साथ काम करने के उदाहरण का उपयोग करते हुए नोडज के लिए C ++ में एक मॉड्यूल लिखते हैं

परिचय

कई लोग पहले से ही Node.js की कोशिश कर चुके हैं, मेरी राय में, यह कई प्रकार के कार्यों को हल करने के लिए बहुत सुविधाजनक उपकरण है। सबसे पहले, जो मुझे Node.js के लिए आकर्षित करता है, वह जावास्क्रिप्ट कोड लिखने की क्षमता है और अक्सर उत्पन्न होने वाले कार्यों को हल करने के लिए अंतर्निहित मॉड्यूल का एक बड़ा सेट है। यदि कुछ मानक पैकेज में नहीं है, तो npmjs.org रिपॉजिटरी में बड़ी संख्या में अतिरिक्त मॉड्यूल मिल सकते हैं

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

दस्तावेज़ीकरण का अध्ययन करने के बाद, मैं इस नतीजे पर पहुंचा कि मैं C ++ में जिस मॉड्यूल की आवश्यकता है, उसे लिख सकता हूं और इसे नोड.जेएस के एडऑन के रूप में डिजाइन कर सकता हूं, यदि आप मॉड्यूल बनाने की प्रक्रिया से परिचित होने में रुचि रखते हैं, तो बिल्ली का स्वागत है।

उपकरण

हम लिनक्स के तहत मॉड्यूल लिखेंगे। हमारे द्वारा आवश्यक उपकरणों से:

• mysql
• नोड
• नोड ढकोसला
• जीसीसी

यह सब आपके वितरण में कैसे स्थापित किया गया है, आपको अपने लिए पता होना चाहिए, नोड-जिप के अपवाद के साथ, यह एनपीएम के माध्यम से स्थापित किया गया है जो नोड की स्थापना के साथ आता है:
npm install node-gyp

मॉड्यूल लिखना

तो नोड.जेएस गूगल वी 8 से जावास्क्रिप्ट इंजन पर बनाया गया एक मंच है। तदनुसार, हमारे मॉड्यूल में हमें वी 8 इंजन की वस्तुओं से निपटना होगा। मेरे जीवन को सरल बनाने के लिए, इस इंजन की वस्तुओं के लिए किसी प्रकार की चीट शीट का होना उचित है, मैंने इसे चुना है, साथ ही MySQL के साथ काम करने के लिए C फ़ंक्शन का एक संदर्भ, उदाहरण के लिए, यहां देखें।

मॉड्यूल किसके साथ शुरू होते हैं?

पहले आपको एक फ़ाइल बनाने की आवश्यकता है, मेरे मामले में यह mysql_sync.cc होगा, जब हम आवश्यक हेडर का वर्णन करते हैं और नाम स्थान सेट करते हैं:

 #include <node.h> #include <node_buffer.h> #include <v8.h> #include <mysql.h> using namespace v8; 

नोड.जेएस के लिए किसी भी मॉड्यूल का संचालन NODE_MODULE मैक्रो के निष्पादन से शुरू होता है, जिसमें मॉड्यूल का नाम और मॉड्यूल कनेक्ट होने पर निष्पादित होने वाले फ़ंक्शन का नाम होता है।

 void init(Handle<Object> target) { target->Set(String::NewSymbol("create"), FunctionTemplate::New(create)->GetFunction()); } NODE_MODULE(mysql_sync, init) 

इसलिए, हम देखते हैं कि, init फ़ंक्शन कुछ भी नहीं लौटाता है, लेकिन एक ऑब्जेक्ट इसे पास किया जाता है। हम इस ऑब्जेक्ट को नाम बनाने के साथ एक संपत्ति जोड़ते हैं , सेट विधि का उपयोग करके, नाम कक्षा V8 स्ट्रिंग का एक ऑब्जेक्ट है और इसे स्थिर फ़ंक्शन NewSymbol का उपयोग करके बनाया गया है, जिसमें हम वांछित लाइन पास करते हैं। इस प्रॉपर्टी की वैल्यू वह फंक्शन होगी जिसे क्रिएट नाम से बनाया जाएगा।
सब कुछ काफी सरल है, लेकिन एक बात है, लेकिन यह फ़ंक्शन केवल एक बार मॉड्यूल के पहले लोडिंग पर कहा जाएगा, जिसके बाद नोड उस वस्तु को कैश करेगा जो इनिट फ़ंक्शन के आउटपुट पर प्राप्त होता है और इसे फिर से कॉल नहीं करेगा।
यदि आप अभी फ़ंक्शन बनाते हैं, तो मॉड्यूल संकलित करें, और नोड में निम्न कोड निष्पादित करें

 console.log(require('./mysql_sync.node')); 

परिणामस्वरूप, स्क्रीन पर हम इस परिणाम को देखेंगे:

 { create: [Function] } 

पहला चरण तैयार है, बनाएं फ़ंक्शन पर जाएं।

हमारे मॉड्यूल की एक वस्तु बनाना

बनाएँ फ़ंक्शन का कोड अलग नहीं है:

 Handle<Value> create(const Arguments& args) { HandleScope scope; Handle<Object> ret = Object::New(); node::Buffer *buf; buf = node::Buffer::New((char *)mysql_init(NULL), sizeof(MYSQL)); ret->SetHiddenValue(String::NewSymbol("MYSQL"), buf->handle_); ret->SetHiddenValue(String::NewSymbol("connected"), Boolean::New(0)); ret->Set(String::NewSymbol("connect"), FunctionTemplate::New(connect)->GetFunction()); ret->Set(String::NewSymbol("query"), FunctionTemplate::New(query)->GetFunction()); return scope.Close(ret); } 

इस कोड का रिटर्न मान कक्षा V8 मान का एक ऑब्जेक्ट है। यह वर्ग सभी जावास्क्रिप्ट फ़ंक्शंस, साथ ही C ++ लौटाता है, यदि उन्हें जावास्क्रिप्ट से बुलाया जाता है। एक नई रीट ऑब्जेक्ट बनाएं जिसमें हम फ़ंक्शन द्वारा लौटाए गए ऑब्जेक्ट के गुणों को संग्रहीत करेंगे। यहां हम, अधिमानतः, एक पॉइंटर को MYSQL संरचना के लिए आरम्भ करते हैं, जिसे अन्य MySQL फ़ंक्शंस के साथ काम करने और किसी तरह इसे हमारी ऑब्जेक्ट में संग्रहीत करने की आवश्यकता होगी। पाया गया कि सभी, बफर ऑब्जेक्ट, जो स्वयं नोड में वर्णित है, संरचना को संग्रहीत करने के लिए उपयुक्त था। नोड :: बफ़र :: नए निर्माण का उपयोग करते हुए, हमने आवश्यक आकार की एक नई वस्तु बनाई और MYSQL इनिशियलाइज़्ड स्ट्रक्चर को वहां रखा (मुझे पता है कि लौटे परिणाम की जांच करना अच्छा होगा, लेकिन मैं फिर से जटिल नहीं होना चाहता, इसलिए कुछ जांचों को और छोड़ दिया जाएगा) ।
MYSQL को हमारी वस्तु में संग्रहीत करने के लिए, लेकिन उपयोगकर्ता को इसे एक्सेस नहीं करने के लिए, ऑब्जेक्ट के छिपे हुए क्षेत्र में संरचना को संग्रहीत करने का विकल्प SetHiddenValue विधि का उपयोग करके चुना गया था, यह पूरी तरह से सेट विधि के समान है, केवल इस तथ्य को छोड़कर कि यह एक नियमित संपत्ति नहीं बनाता है, लेकिन एक छिपा हुआ है, अर्थात्। जावास्क्रिप्ट कोड से दुर्गम। हम कनेक्टेड प्रॉपर्टी को एक छिपे हुए क्षेत्र में भी संग्रहीत करेंगे, यह बाद में हमारे लिए उपयोगी होगा, लेकिन अब हम इसमें एक V8 बूलियन ऑब्जेक्ट डालेंगे (मूल्य के साथ)। जब हम दो और कार्य जोड़ते हैं : कनेक्ट और क्वेरी करें । और अंत में, हम अपनी वस्तु को लौटाते हैं, जो कि स्कोप का उपयोग करके अपने कार्यों को बुलाती है।
अंत में, हमें एक फ़ंक्शन मिलता है जो एक नई ऑब्जेक्ट बनाता है, इस ऑब्जेक्ट के लिए सेवा डेटा के साथ दो छिपे हुए गुणों को जोड़ता है, और दो सार्वजनिक गुण जो हमें आवश्यक फ़ंक्शन को संग्रहीत करते हैं।
यदि आप दो निर्दिष्ट कार्यों पर स्टब्स बनाते हैं और निर्दिष्ट कोड निष्पादित करते हैं:

 console.log(require('./mysql_sync.node').create()); 

तब हमें निम्न परिणाम मिलते हैं:

 { connect: [Function], query: [Function]} 

हमारे मॉड्यूल के तरीके

अब, हम अपने मॉड्यूल के तरीकों का वर्णन करते हैं:
कनेक्ट विधि:

 Handle<Value> connect(const Arguments& args) { HandleScope scope; Handle<Object> ret = Object::New(); Handle<Object> err = Object::New(); MYSQL *mysql; bool ok=true; mysql = (MYSQL *)args.Holder()->GetHiddenValue(String::NewSymbol("MYSQL"))-> ToObject()->GetIndexedPropertiesExternalArrayData(); if(args.Length()==4){ for(int i=0; i<4; i++) if(!args[i]->IsString()) ok=false; } else { ok=false; } if(ok == true){ String::AsciiValue host(args[0]->ToString()); String::AsciiValue user(args[1]->ToString()); String::AsciiValue pass(args[2]->ToString()); String::AsciiValue db(args[3]->ToString()); mysql_real_connect(mysql, *host, *user, *pass, *db, 0, NULL, 0); args.Holder()->SetHiddenValue(String::NewSymbol("connected"), Boolean::New(1)); err->Set(String::NewSymbol("id"), Uint32::New(mysql_errno(mysql))); err->Set(String::NewSymbol("text"), String::NewSymbol(mysql_error(mysql))); } else { err->Set(String::NewSymbol("id"), Uint32::New(65535)); err->Set(String::NewSymbol("text"), String::NewSymbol("Incorect parametrs of function")); } ret->Set(String::NewSymbol("err"), err); return scope.Close(ret); } 

फिर मैं पहली मुश्किल में आया, हमें स्पष्ट रूप से वह वस्तु नहीं दी गई है जिसे इस विधि कहा जाता है, और वस्तु में दो छिपे हुए क्षेत्र हैं जिन्हें हमें आगे काम करने की आवश्यकता है। लेकिन फ़ंक्शन के तर्कों को V8 तर्क ऑब्जेक्ट द्वारा पारित किया जाता है, इसके विवरण में विलंब करने के बाद, हम पाते हैं कि यह उस ऑब्जेक्ट के संदर्भ को संग्रहीत करता है जो इसे पारित किया था। इसे प्राप्त करने के लिए, हम धारक () विधि का उपयोग करते हैं, जिसके बाद हमें MYSQL संरचना के साथ एक छिपा हुआ क्षेत्र मिलता है और GetIndexedPropertiesExternalArrayData () विधि का उपयोग करके, हम संरचना को एक संकेतक प्राप्त करते हैं। कोड में कुछ और उल्लेखनीय नहीं है; कितने मापदंडों को पारित किया गया था और किस प्रकार के लिए चेक हैं। यदि सब कुछ सही ढंग से mysql_real_connect () फ़ंक्शन कहलाता है, तो हमें mysql त्रुटियाँ मिलती हैं, एक गलत ऑब्जेक्ट बनाते हैं और फ़ील्ड मानों के रूप में वहाँ त्रुटियाँ जोड़ते हैं। यदि पैरामीटर वे नहीं हैं जो वे अपेक्षा करते हैं, तो हमारी त्रुटि को गलत ऑब्जेक्ट में जोड़ें। फिर हम गलत ऑब्जेक्ट को "ऑब्जेक्ट" फ़ील्ड के रूप में रिट ऑब्जेक्ट में जोड़ते हैं और इस ऑब्जेक्ट को वापस करते हैं।

क्वेरी विधि:

 Handle<Value> query(const Arguments& args) { HandleScope scope; Handle<Object> ret = Object::New(); Handle<Object> err = Object::New(); Handle<Array> rows = Array::New(); Handle <Script> script; Handle<Object> obj_row; node::Buffer *buf; MYSQL *mysql; MYSQL_RES *res; MYSQL_ROW row; MYSQL_FIELD *fields; unsigned int num_fields; bool ok=true; mysql = (MYSQL *)args.Holder()->GetHiddenValue( String::NewSymbol("MYSQL"))->ToObject()->GetIndexedPropertiesExternalArrayData(); if(!args.Holder()->GetHiddenValue(String::NewSymbol("connected"))->BooleanValue()){ err->Set(String::NewSymbol("id"), Uint32::New(65534)); err->Set(String::NewSymbol("text"), String::NewSymbol("You need to connect before any query")); ret->Set(String::NewSymbol("err"), err); ok = false; } if(ok == true){ if(args.Length()!=1){ ok=false; }else{ if(!args[0]->IsString()) ok=false; } if(ok == false){ err->Set(String::NewSymbol("id"), Uint32::New(65535)); err->Set(String::NewSymbol("text"), String::NewSymbol("Incorect parametrs of function")); } } if(ok == true){ String::AsciiValue query(args[0]->ToString()); if(mysql_query(mysql, *query)==0){ res = mysql_store_result(mysql); num_fields = mysql_num_fields(res); fields = mysql_fetch_fields(res); while ( (row = mysql_fetch_row(res)) ){ obj_row = Object::New(); for(unsigned int i=0; i<num_fields; i++){ switch(fields[i].type){ case MYSQL_TYPE_DECIMAL: case MYSQL_TYPE_TINY: case MYSQL_TYPE_SHORT: case MYSQL_TYPE_LONG: case MYSQL_TYPE_LONGLONG: case MYSQL_TYPE_INT24: case MYSQL_TYPE_FLOAT: case MYSQL_TYPE_DOUBLE: obj_row->Set(String::NewSymbol(fields[i].name), Number::New( (row[i])? atof(row[i]):0) ); break; case MYSQL_TYPE_TIMESTAMP: case MYSQL_TYPE_DATE: case MYSQL_TYPE_TIME: case MYSQL_TYPE_DATETIME: case MYSQL_TYPE_YEAR: case MYSQL_TYPE_NEWDATE: script = Script::Compile( String::NewSymbol("")->Concat( String::NewSymbol("")->Concat( String::NewSymbol("new Date(Date.parse('"), String::NewSymbol( (row[i])? row[i]:"" ) ), String::NewSymbol("'))")) ); obj_row->Set(String::NewSymbol(fields[i].name), script->Run()); break; case MYSQL_TYPE_TINY_BLOB: case MYSQL_TYPE_MEDIUM_BLOB: case MYSQL_TYPE_LONG_BLOB: case MYSQL_TYPE_BLOB: if((fields[i].flags & BINARY_FLAG)){ buf = node::Buffer::New(row[i], mysql_fetch_lengths(res)[i]); obj_row->Set(String::NewSymbol(fields[i].name), buf->handle_); break; } default: obj_row->Set(String::NewSymbol(fields[i].name), String::NewSymbol( (row[i])? row[i]:"") ); break; } } rows->Set(rows->Length(),obj_row); } mysql_free_result(res); }; ret->Set(String::NewSymbol("inserted_id"), Uint32::New(mysql_insert_id(mysql))); ret->Set(String::NewSymbol("info"), String::NewSymbol( (mysql_info(mysql)) ? mysql_info(mysql) :"" )); ret->Set(String::NewSymbol("affected_rows"), Uint32::New(mysql_affected_rows(mysql))); err->Set(String::NewSymbol("id"), Uint32::New(mysql_errno(mysql))); err->Set(String::NewSymbol("text"), String::NewSymbol(mysql_error(mysql))); } ret->Set(String::NewSymbol("err"), err); ret->Set(String::NewSymbol("rows"), rows); return scope.Close(ret); } 

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

• MYSQL_TYPE_DECIMAL
• MYSQL_TYPE_TINY
• MYSQL_TYPE_SHORT
• MYSQL_TYPE_LONG
• MYSQL_TYPE_LONGLONG
• MYSQL_TYPE_INT24
• MYSQL_TYPE_FLOAT
• MYSQL_TYPE_DOUBLE

एक V8 नंबर के लिए डाली जाती हैं जो एक जावास्क्रिप्ट संख्या से मेल खाती है।

प्रकार के साथ फ़ील्ड:

• MYSQL_TYPE_TINY_BLOB
• MYSQL_TYPE_MEDIUM_BLOB
• MYSQL_TYPE_LONG_BLOB
• MYSQL_TYPE_BLOB

बाइनरी के लिए जाँच की जाती है और यदि यह एक बाइनरी BLOB'y है तो बफ़र में परिवर्तित हो जाती है, यदि V8 स्ट्रिंग में नहीं है।

और प्रकार के साथ क्षेत्र:

• MYSQL_TYPE_TIMESTAMP
• MYSQL_TYPE_DATE
• MYSQL_TYPE_TIME
• MYSQL_TYPE_DATETIME
• MYSQL_TYPE_YEAR
• MYSQL_TYPE_NEWDATE

वी 8 दिनांक में परिवर्तित करने का निर्णय लिया गया। और यहाँ एक रोड़ा बन गया। V8 दिनांक ऑब्जेक्ट बनाने के लिए, आपको यूनिक्स टाइमस्टैम्प को पास करना होगा, और mysql YYYY-MM-DD HH: MM: SS प्रारूप में एक फ़ील्ड देता है। मैं लाइन पार्सिंग और आगे रूपांतरण लिखना नहीं चाहता था। उसी समय, मुझे याद आया कि जावास्क्रिप्ट पूरी तरह से यूनिक्स टाइमस्टैम्प में इस तरह के प्रवेश को पूरी तरह से परिवर्तित करता है। और चूंकि V8 हमारे लिए उपलब्ध है, इसलिए इसका उपयोग क्यों न करें। ऐसा करने के लिए, हम स्क्रिप्ट :: कंपाइल विधि का उपयोग करके V8 स्क्रिप्ट क्लास का एक स्क्रिप्ट ऑब्जेक्ट बनाते हैं, जिसमें हम स्क्रिप्ट स्ट्रिंग न्यू डेट (Date.parse (mysql_field_value)) पास करते हैं । फिर हम रन () विधि को कॉल करते हैं, जो जावास्क्रिप्ट कोड को निष्पादित करके प्राप्त वस्तु पर वापस आ जाएगी। और हम, बदले में, इसे हमारी वी 8 एरे पंक्तियों में डालते हैं। शायद बहुत सुंदर नहीं, लेकिन काफी दिलचस्प।
अब यह सब संकलित करना बाकी है, इसके लिए हमें निम्नलिखित सामग्री के साथ एक बाइंडिंग.गाइप फ़ाइल बनाने की आवश्यकता है:

 { "targets": [ { "target_name": "mysql_sync", "sources": [ "mysql_sync.cc" ], "include_dirs": [ '/server/daemons/mysql/include/mysql/' ], "link_settings": { 'libraries': ['-lmysqlclient -L/server/daemons/mysql/lib/mysql/'], 'library_dirs': ['/server/daemons/mysql/lib/mysql/'], }, } ] } 

मैं आपको इस तथ्य पर ध्यान देने के लिए कहता हूं कि यहां अजीब तरीके इंगित किए गए हैं (वे शायद आपके लिए अलग होंगे), ताकि आप उन्हें प्राप्त कर सकें कमांड का उपयोग कर सकें:
mysql_config --include --libs
अब इस पर अमल करना बाकी है:
node-gyp configure
node-gyp build
cp build/Release/mysql_sync.node ./
हमारा मॉड्यूल उपयोग करने के लिए तैयार है, परीक्षण के लिए हम निम्नलिखित कोड लिखेंगे:

 var mysql = require('./mysql_sync.node').create(); console.log(mysql.connect("localhost", "login", "pass", "test")); console.log(mysql.query("select * from tmp"); 

परिणाम:

1. हमें उपयोग के लिए एक मॉड्यूल तैयार है, यह सबसे अच्छा नहीं हो सकता है, लेकिन यह वह है जो हमें चाहिए, कभी-कभी यह सबसे महत्वपूर्ण है
2. Node.js के लिए C ++ में अपने खुद के मॉड्यूल लिखने का तरीका सीखा
3. हमने मॉड्यूल से मनमाना जावास्क्रिप्ट कोड कॉल करना सीखा
4. हम किसी अन्य मॉड्यूल को लिख सकते हैं यदि हमें इसकी आवश्यकता है
5. V8 जावास्क्रिप्ट वस्तुओं के साथ अनुभव प्राप्त किया

लेख मेरी अपेक्षा से अधिक लंबा निकला, लेकिन मुझे लगता है कि यह आपके मॉड्यूल को लिखते समय बहुत से काम में आ सकता है, या जब यह जानने का प्रयास किया जाता है कि अन्य डेवलपर्स के मॉड्यूल में क्या हो रहा है, जो कभी-कभी समान रूप से महत्वपूर्ण होता है। आपका ध्यान देने के लिए धन्यवाद।