5 मिनट में MySQL इंजन

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

• int rnd_init (बूल स्कैन);
• int rnd_next (uchar * buf);
• int write_row (uchar * buf);
• int delete_row (const uchar * buf);

आइए एक सिंगली लिंक्ड सूची और सिर, वर्तमान, पिछली और अगली सूची आइटम ( ha_smalldb.h में ) के लिए कई बिंदुओं के लिए एक पूर्व निर्धारित जोड़कर शुरू करें:

 class node{ public: uchar* data; //   node* next; //     node(){ data=NULL; next=NULL; } ~node(){ free(data); } }; node *first, *cur, *prev, *next; int row_count, cur_pos; void append_node(node* n){ if (first==NULL){ first=n; }else{ node* iter=first; while (iter->next!=NULL){iter=iter->next;} iter->next=n; } } 

अब लिखने के ऑपरेशन पर चलते हैं - write_row (uchar * buf) । एक तर्क के रूप में, buf को इसे पास कर दिया जाता है, जिसमें आंतरिक प्रतिनिधित्व में जोड़े गए स्ट्रिंग की सामग्री शामिल होती है:


चूंकि हम प्रारंभिक प्रसंस्करण के बिना डेटा को मेमोरी में सहेजेंगे, इसलिए हम केवल स्ट्रिंग की संपूर्ण सामग्री को कॉपी कर सकते हैं। मेटाडेटा के साथ पंक्ति की लंबाई तालिका डिस्क्रिप्टर तालिका-> s-> पुनर्गणना से प्राप्त की जा सकती है।

 int ha_smalldb::write_row(uchar *buf) { DBUG_ENTER("ha_smalldb::write_row"); node* n=new node(); n->data = (uchar*) malloc(sizeof(uchar)*table->s->reclength); memcpy(n->data,buf,table->s->reclength); append_node(n); row_count++; DBUG_RETURN(0); } 

तालिका से डेटा पढ़ते समय, rnd_init और rnd_next के एक समूह का उपयोग करके अनुक्रमिक स्कैनिंग का उपयोग किया जाता है । इसका उपयोग अगर इंजन इंडेक्स या प्राथमिक कुंजी का समर्थन नहीं करता है। सबसे पहले, आपको rnd_init () में पॉइंटर्स तैयार करने की आवश्यकता है।

 int ha_smalldb::rnd_init(bool scan) { DBUG_ENTER("ha_smalldb::rnd_init"); cur=NULL; prev=NULL; next=first; cur_pos=0; DBUG_RETURN(0); } 

बूलियन तर्क स्कैन डेटाबेस के इरादे को बेतरतीब ढंग से (असंगत) तालिका को पढ़ने का संकेत देता है। हम इसे सुरक्षित रूप से अनदेखा कर सकते हैं, क्योंकि जब आप अवास्तविक rnd_pos () कमांड को कॉल करने का प्रयास करते हैं, तो डेटाबेस प्रतिक्रिया में HA_ERR_WRONG_COMMAND प्राप्त करेगा और अनुमान लगाएगा कि आपको क्रम में पढ़ना होगा।
एकल rnd_init () के बाद, डेटाबेस rnd_next () को क्रमिक रूप से तब तक कॉल करेगा जब तक यह तालिका के अंत तक नहीं पहुंचता - HA_ERR_END_OF_FILE। प्रत्येक कॉल के बाद, बुफ़ पर मेमोरी को आंतरिक प्रतिनिधित्व में स्ट्रिंग की सामग्री से भरना चाहिए।

 int ha_smalldb::rnd_next(uchar *buf) { int rc; DBUG_ENTER("ha_smalldb::rnd_next"); MYSQL_READ_ROW_START(table_share->db.str, table_share->table_name.str, TRUE); if (next!=NULL){ prev=cur; cur=next; next=cur->next; memcpy(buf,cur->data,table->s->reclength); cur_pos++; rc=0; }else{ rc= HA_ERR_END_OF_FILE; } MYSQL_READ_ROW_DONE(rc); DBUG_RETURN(rc); } 

अंत में, हम सूची से वर्तमान आइटम को हटाकर delete_row () लिखते हैं:

 int ha_smalldb::delete_row(const uchar *buf) { DBUG_ENTER("ha_smalldb::delete_row"); if (cur!=first){ free(cur); prev->next=next; }else{ free(cur); cur=NULL; first=next; } row_count--; DBUG_RETURN(0); } 

बस इतना ही, अब आप मिनी-एक्शन का अनुभव कर सकते हैं।



INSERT और SELECT के अलावा, आप LIKE , INNER JOIN , आदि ऑपरेटरों का उपयोग करके और भी अधिक जटिल SQL प्रश्नों को निष्पादित कर सकते हैं, क्योंकि SQL क्वेरीज़ का अनुकूलन इंजन पर नियंत्रण स्थानांतरित करने से पहले डेटाबेस कर्नेल स्तर पर लागू किया जाता है, लेकिन इसका प्रभाव निश्चित रूप से इंजन द्वारा समर्थित कार्यक्षमता पर निर्भर करता है।
मुझे आशा है कि यह सामग्री आपको MySQL प्लग-इन के इंटरफ़ेस से थोड़ा परिचित होने की अनुमति देती है। पूरा प्रोजेक्ट कोड github पर डाउनलोड किया जा सकता है।
जो लोग अधिक गंभीरता से MySQL इंजन के आंतरिक अध्ययन करना चाहते हैं, लेकिन InnoDB के पास जाने का जोखिम नहीं उठाते हैं, मैं आपको CSV या HEAP (नया नाम - मेमोरी) पर ध्यान देने की सलाह देता हूं। CSV उसी प्रारूप में डेटा को डिस्क में सहेजने की क्षमता जोड़ता है। और HEAP, जैसा कि नाम से ही स्पष्ट है, डेटा को ढेर में व्यवस्थित करता है और हैश इंडेक्स समर्थन को लागू करता है। दोनों ही मामलों में, हमें लाइनों को हटाने के बाद मेमोरी के मुक्त वर्गों को मुक्त करने की सहायक समस्या को हल करना होगा, जिसे हम एक एकल लिंक की गई सूची का उपयोग करके बचने में कामयाब रहे।
अपने स्वयं के इंजनों को लिखने के बारे में अधिक विस्तृत मार्गदर्शिका आधिकारिक MySQL इंटरनेशनल मैनुअल के अध्याय 22 में पाई जा सकती है । अध्याय 22. एक कस्टम संग्रहण इंजन लिखना ।
PS और अंत में, मैं उन लोगों के लिए ctags उपयोगिता की सिफारिश करना चाहता हूं जो इससे परिचित नहीं हैं। विभिन्न फ़ाइलों में बिखरे हुए कोड का अध्ययन करने के लिए इसका उपयोग करना काफी सुविधाजनक है, उदाहरण के लिए, यह आपको CTRL + द्वारा किसी फ़ंक्शन या चर की परिभाषा में कूदने की अनुमति देता है। Vim, emacs और अन्य लोकप्रिय संपादकों का समर्थन है। यहाँ एक त्वरित गाइड है ।