👸🏾 ➖ 🎒 Neo4j ग्राफ डेटाबेस के साथ आरंभ करना 🐶 🛩️ ♻️

हमारी परियोजना में निम्नलिखित कार्य उत्पन्न हुए - बड़ी संख्या में सामान के साथ एक आधार है, सैकड़ों हजारों के स्तर पर। प्रत्येक उत्पाद में गतिशील रूप से उत्पन्न विशेषताओं के सैकड़ों होते हैं। विभिन्न विशेषताओं के एक सेट के अनुसार उत्पाद द्वारा त्वरित फ़िल्टरिंग प्रदान करना आवश्यक है। प्रतिक्रिया गठन का समय 0.3 सेकंड से अधिक नहीं होना चाहिए, आपको शैली में जटिल तर्क बनाए रखने की आवश्यकता है।

(1 = true AND (2 < 100)) OR (1 = false AND (3 > 17)) ...     AND\OR

ऐसी कार्यक्षमता का एक विशिष्ट उदाहरण hotline.ua/computer/myshi-klaviatury है

कार्यात्मक उदाहरण

हमारे पास MySQL + Symfony2 / Doctrine के ढांचे में सब कुछ लागू है, गति असंतोषजनक है - जवाब 1-10 सेकंड के भीतर बनते हैं। इस सभी अर्थव्यवस्था को अनुकूलित करने के मेरे प्रयास कट के तहत हैं।

माल को छानने के कार्य की शब्दावली (सरलीकृत रूप में)

विशेषता - माल की एक विशिष्ट संपत्ति। उदाहरण के लिए, स्मृति की मात्रा।
उत्पाद टेम्पलेट - समान उत्पादों की सभी संभावित विशेषताओं का एक सेट, उदाहरण के लिए, कंप्यूटर चूहों की संभावित विशेषताओं की एक सूची। एक नया उत्पाद जोड़ते समय, व्यवस्थापक टेम्पलेट के भीतर विशेषताओं का चयन कर सकता है। एक उत्पाद के लिए एक नई विशेषता जोड़ना असंभव है - आपको इस उत्पाद के लिए टेम्पलेट में एक विशेषता जोड़ने की आवश्यकता है। इसी समय, यह सुविधा इस टेम्पलेट का उपयोग करने वाले सभी उत्पादों के लिए उपलब्ध होगी।
उत्पाद समूह - एक टेम्पलेट पर आधारित उत्पाद । उदाहरण के लिए, कंप्यूटर चूहों। फ़िल्टरिंग केवल एक समूह के उत्पादों के लिए की जाती है।
मानदंड - एक तार्किक नियम, जिसमें माल की विशेषताओं के लिए औपचारिक आवश्यकताओं का एक सेट होता है। उदाहरण के लिए, "गेमिंग माउस" प्रदर्शन आवश्यकताओं (आकार छोटा नहीं है) और (लेजर सेंसर) और (कम से कम 1500 का सेंसर संकल्प) का एक सेट है
फ़िल्टर - समान उत्पादों के लिए मापदंड का एक समूह। मानदंडों के आधार पर, उन्हें AND या OR के माध्यम से जोड़ा जा सकता है

हॉटलाइन का एक अधिक उन्नत संस्करण है - एक संकेत के साथ कि कसौटी की सक्रियता के बाद कितने उत्पाद बने रहेंगे। उदाहरण के लिए, यदि आप "ब्लूटूथ" फ़िल्टर का चयन करते हैं, तो पृष्ठ लोड करने के बाद, "माउस सेंसर प्रकार ऑप्टिकल है" फिल्टर 17 होगा। वास्तव में, इस तरह के कार्यान्वयन के लिए, आपको न केवल मानदंडों के अनुसार चयन करने की आवश्यकता है, बल्कि पहले प्रत्येक शेष फ़िल्टर के लिए उत्पादों की संख्या की भी गणना करें। इसकी सक्रियता।

इस समस्या को हल करने के लिए, मैंने Neo4j ग्राफ डेटाबेस को आज़माने का फैसला किया। सतही समीक्षा के लिए, मैं इस पोस्ट को पढ़ने की सलाह देता हूं।

Neo4j की शब्दावली और सामान्य रूप से ग्राफ़ डेटाबेस।

ग्राफ़ डेटाबेस , ग्राफ़ डेटाबेस - ग्राफ़ पर निर्मित डेटाबेस - नोड्स और उनके बीच के रिश्ते
साइरोफ़र - Neo4j डेटाबेस के प्रश्नों को लिखने के लिए एक भाषा (लगभग, SQL में SQL की तरह)
नोड , नोड - डेटाबेस में एक वस्तु, एक ग्राफ नोड। नोड्स की संख्या 2 से 35 ~ 34 बिलियन की शक्ति तक सीमित है
नोड लेबल , नोड लेबल - एक सशर्त "नोड प्रकार" के रूप में उपयोग किया जाता है। उदाहरण के लिए, टाइप मूवी के नोड्स टाइप एक्टर के नोड्स से जुड़े हो सकते हैं। लेबल नोड केस-संवेदी होते हैं , और यदि आप गलत रजिस्टर में नाम टाइप करते हैं तो साइप्रो एरर उत्पन्न नहीं करता है।
संबंध , संचार - दो नोड्स के बीच का संबंध, ग्राफ के किनारे। बांड की संख्या 35 ~ 34 बिलियन की शक्ति तक 2 तक सीमित है
संबंध पहचानकर्ता , कनेक्शन का प्रकार कनेक्शन के लिए Neo4j में है। लिंक प्रकारों की अधिकतम संख्या 32767 है
गुण , नोड गुण - डेटा का एक सेट जिसे नोड को सौंपा जा सकता है। उदाहरण के लिए, यदि एक नोड एक उत्पाद है, तो नोड के गुणों में आप उत्पाद आईडी को MySQL डेटाबेस से स्टोर कर सकते हैं
नोड आईडी , नोड आईडी - नोड के लिए एक विशिष्ट पहचानकर्ता। डिफ़ॉल्ट रूप से, परिणाम देखते समय, यह आईडी प्रदर्शित होता है। मुझे यह नहीं मिला कि इसे साइफ्रेक अनुरोधों में कैसे उपयोग किया जाए

समस्या के समाधान के लिए योजना

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

पहला समाधान Neo4j के साथ है

यह समझते हुए कि मैंने कभी ग्राफ़ डेटाबेस के साथ काम नहीं किया, मैंने निओ 4 जे को स्थानीय रूप से तैनात करने का फैसला किया, एक बुनियादी स्तर पर साइफर का अध्ययन किया और आवश्यक तर्क को लागू करने का प्रयास किया। अगर सब कुछ काम करता है, 1 मिलियन उत्पादों के डेटाबेस के लिए काम की गति का परीक्षण करें, प्रत्येक में 500 विशेषताएँ हैं।

सिस्टम की तैनाती काफी सरल है - वितरण किट डाउनलोड करें और इसे स्थापित करें।

Neo4j सर्वर में RestAPI है, php के लिए neo4jphp लाइब्रेरी है। Symfony2 के साथ एकीकरण के लिए एक बंडल भी है - klaussilveira / neo4j-ogm-बंडल ।

वितरण में एक वेब सर्वर और इसके साथ काम करने के लिए एक एप्लिकेशन शामिल है, डिफ़ॉल्ट रूप से http: // localhost: 7474 /
अन्य कार्यक्षमता के साथ अभी भी क्लाइंट का एक पुराना संस्करण है ।

प्रलेखन के रूप में संक्षिप्त प्रलेखन का उपयोग करना सुविधाजनक है। कोड उदाहरण ग्राफगिस्ट में हैं। सिद्धांत रूप में, उन्हें वहां ऑनलाइन निष्पादित किया जाना चाहिए, लेकिन अब यह काम नहीं करता है। कोड को देखने के लिए आपको ग्राफगिस्ट के लिंक का अनुसरण करना होगा (उदाहरण के लिए, यहां ) और पृष्ठ स्रोत बटन पर क्लिक करें।

Neo4j के साथ प्रयोगों के लिए बिल्ट-इन वेब क्लाइंट का उपयोग करना बहुत सुविधाजनक है । वहां आप साइफ्रो अनुरोधों को निष्पादित कर सकते हैं और नोड्स के कनेक्शन और विशेषताओं के साथ अनुरोधों की प्रतिक्रिया देख सकते हैं।

Node4j एंबेडेड क्लाइंट

सिंपल साइपर कमांड्स

एक लेबल के साथ एक नोड बनाना

 create (n:Ware {wareId: 1});

सभी नोड्स का चयन करें

 MATCH (n) RETURN n;

काउंटर

 MATCH (n:Ware {wareId:1}) RETURN "Our graph have "+count(*)+" Nodes with label Ware and wareId=1" as counter;

2 संबंधित नोड बनाएं

 CREATE (n{wareId:1})-[r:SUIT]->(m{criteriaId:1})

लिंक 2 मौजूदा नोड्स

 MATCH (a {wareId: 1}), (b {criteriaId: 2}) MERGE (a)-[r:SUIT]->(b)

सभी संबंधित नोड्स हटाएँ

 match (n)-[r]-() DELETE n,r;

सभी असंबंधित नोड्स को हटाएं - यदि आप इस कमांड को डेटाबेस में चलाने की कोशिश करते हैं जहां संबंधित नोड्स हैं, तो यह काम नहीं करेगा। आपको पहले संबंधित नोड्स को निकालना होगा।

 match n DELETE n;

मापदंड 3 से मेल खाने वाले उत्पादों का चयन करें

 MATCH (a:Ware)-->(b:Criteria {criteriaId: 3}) RETURN a;

एक बार कई Cypher आदेशों पर वेब क्लाइंट निष्पादित करने में सक्षम नहीं है। वे कहते हैं कि पुराने ग्राहक को पता है कि कैसे, लेकिन मुझे ऐसा अवसर नहीं मिला। इसलिए, आपको 1 पंक्ति की प्रतिलिपि बनाने की आवश्यकता है।

आप एक आदेश के साथ लिंक के साथ कई नोड बना सकते हैं, आपको नोड्स को अलग-अलग नाम देने की आवश्यकता है, आप लिंक को कोई नाम नहीं दे सकते

 CREATE (w1:Ware{wareId:1})-[:SUIT]->(c1:Criteria{criteriaId:1}), (w2:Ware{wareId:2})-[:SUIT]->(c2:Criteria{criteriaId:2}), (w3:Ware{wareId:3})-[:SUIT]->(c3:Criteria{criteriaId:3}), (w4:Ware{wareId:4})-[:SUIT]->(c1), (w5:Ware{wareId:5})-[:SUIT]->(c1), (w4)-[:SUIT]->(c2), (w5)-[:SUIT]->(c3);

आपको ऐसी संरचना मिलती है। यदि यह आपको कम स्पष्ट दिखता है, तो आप माउस से नोड्स को फिर से व्यवस्थित कर सकते हैं।

परीक्षण संरचना

इंटरमीडिएट Neo4j स्पीड टेस्ट

बड़े डेटाबेस से डेटाबेस और सरल नमूनों को भरने की गति का परीक्षण करने का समय आ गया है।

ऐसा करने के लिए, क्लोन neo4jphp

 git clone https://github.com/jadell/neo4jphp.git

इस लाइब्रेरी का मूल विवरण इस पोस्ट में है , इसलिए मैं उदाहरण / test_fill_1.php टेस्ट बेस को पॉप्युलेट करने के लिए तुरंत कोड निकालूंगा।

 <?php use Everyman\Neo4j\Client, Everyman\Neo4j\Index\NodeIndex, Everyman\Neo4j\Relationship, Everyman\Neo4j\Node, Everyman\Neo4j\Cypher; require_once 'example_bootstrap.php'; $neoClient = new Client(); $neoWares = new NodeIndex($neoClient, 'Ware'); $neoCriterias = new NodeIndex($neoClient, 'Criteria'); $neoWareLabel = $neoClient->makeLabel('Ware'); $neoCriteriaLabel = $neoClient->makeLabel('Criteria'); $wareTemplatesCount = 200; //    $criteriasCount = 500; //   $waresCount = 10000; //   $commitWares = 100; //  ,     1 batch $minRelations = 200; //       $maxRelations = 400; //       $time = time(); for($wareTemplateId = 0;$wareTemplateId<$wareTemplatesCount;$wareTemplateId++) { $neoClient->startBatch(); print $wareTemplateId." (".$criteriasCount." criterias, ".$waresCount." wares with rand(".$minRelations.",".$maxRelations.") ..."; $criterias = array(); //   for($criteriaId = 1;$criteriaId <=$criteriasCount;$criteriaId++) { $c = $neoClient->makeNode()->setProperty('criteriaId', $wareTemplateId * $criteriasCount + $criteriaId)->save(); // ->addLabels(array($neoCriteriaLabel)) -    commitBatch $neoCriterias->add($c, 'criteriaId', $wareTemplateId * $wareTemplatesCount + $criteriaId); // ->save()    $criterias[] = $c; } //   for($wareId = 1;$wareId <=$waresCount;$wareId++) { $w = $neoClient->makeNode()->setProperty('wareId', $wareTemplateId * $waresCount + $wareId)->save(); // ->addLabels(array($neoWareLabel)) -    commitBatch $neoWares->add($c, 'wareId', $wareTemplateId * $waresCount + $criteriaId); //        for($i = 1;$i<=rand($minRelations,$maxRelations);$i++) { $w->relateTo($criterias[array_rand($criterias)], "SUIT")->save(); } if(($wareId % $commitWares) == 0) { // ,     Neo4j  $neoClient->commitBatch(); print " [commit ".$commitWares." ".(time() - $time)." sec]"; $time = time(); $neoClient->startBatch(); } } $neoClient->commitBatch(); print " done in ".(time() - $time)." seconds\n"; $time = time(); }

मैंने रात के लिए आधार भरने के लिए स्क्रिप्ट छोड़ दी। लगभग 4 घंटे के बाद, स्क्रिप्ट ने डेटा जोड़ना बंद कर दिया और Neo4j सेवा ने सर्वर को 100% लोड करना शुरू कर दिया। सुबह, काम के परिणामों के अनुसार, 8 श्रेणियों के सामानों में से 78,300 उत्पाद डाले गए।
डेटाबेस के परीक्षण भरने के परिणाम 200-400 कनेक्शन के साथ लगभग 20 उत्पाद प्रति सेकंड हैं। बहुत अधिक परिणाम नहीं - मैसिकेल और कैसेंड्रा ने प्रति सेकंड (10 फ़ील्ड, 1 प्राथमिक सूचकांक, 1 सूचकांक) के बारे में 10-20 हजार आवेषण का उत्पादन किया। लेकिन प्रविष्टि गति हमारे लिए महत्वपूर्ण नहीं है - हम उत्पाद को संपादित करने के बाद पृष्ठभूमि में डेटा ग्राफ को अपडेट कर सकते हैं। लेकिन डेटा सैंपलिंग की गति महत्वपूर्ण है।

डिस्क पर परीक्षण डेटाबेस का आकार 1781 मेगाबाइट है। यह 78,300 उत्पादों, 4,000 मानदंडों, 156.66 मिलियन-31320000 कनेक्शनों को संग्रहीत करता है। ऑब्जेक्ट की कुल संख्या (नोड्स और लिंक) 32 मिलियन से कम है - प्रति इकाई औसत 55 बाइट्स। थोड़ा बहुत, जैसा कि मेरे लिए है, लेकिन मुख्य आवश्यकता अभी भी नमूनों की गति है, और डेटाबेस का आकार नहीं है।

नमूनाकरण गति का परीक्षण करने का पहला प्रयास विफल रहा - Neo4j सर्वर फिर से "100% प्रोसेसर लोड मोड में" चला गया और कुछ ही मिनटों में अनुरोध पर प्रतिक्रिया नहीं दी।

 MATCH (c {criteriaId: 1})<--(a)-->(b {criteriaId: 3}) RETURN a.wareId;

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

 START n=node:nodeIndexName(key={value}) MATCH (c)<--(a)-->(b) RETURN a.wareId;

ऐसा करने के लिए, आपको डेटाबेस में अनुक्रमित करने की आवश्यकता है। Neo4j में मुझे वर्तमान सूचकांकों की सूची देखने के लिए एक कमांड नहीं मिली, लेकिन Neo4j वेब एप्लिकेशन में आप कमांड टाइप कर सकते हैं

 :schema

आप कमांड के साथ इंडेक्स जोड़ सकते हैं

 CREATE INDEX ON :Criteria(criteriaId)

टीम द्वारा एक अद्वितीय सूचकांक बनाया जा सकता है

 CREATE CONSTRAINT ON (n:Criteria) ASSERT n.criteriaId IS UNIQUE;

ऊपर दिए गए आदेशों द्वारा जोड़े गए अनुक्रमों का उपयोग START निर्देश में नहीं किया जा सकता है। उनका दावा है कि उनका उपयोग केवल जहां में किया जा सकता है

Cypher के माध्यम से बनाए गए इंडेक्स को स्कीमा इंडेक्स कहा जाता है, और इसे START क्लाज में उपयोग नहीं किया जाता है। START क्लॉज़ इंडेक्स लुकअप उन विरासत इंडेक्स के लिए आरक्षित होते हैं, जो आप ऑटोइंडेक्सिंग के माध्यम से या गैर-साइरफाइ एपीआई के माध्यम से बनाते हैं।

उपयोग करने के लिए: आपके द्वारा बनाया गया उपयोगकर्ता सूचकांक, आप ऐसा कर सकते हैं:

मैच n: उपयोगकर्ता
जहाँ n.name = "aapo"
वापसी n;

यदि मैं प्रलेखन को सही ढंग से समझता हूं, तो आप START के बजाय WHERE का उपयोग सुरक्षित रूप से कर सकते हैं

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

तो पहला काम अनुरोध पैदा हुआ था

 MATCH (a:Ware)-->(c1:Criteria {criteriaId: 3}),(c2:Criteria {criteriaId: 1}),(c3:Criteria {criteriaId: 2}) WHERE (a)-->(c2) AND (a)-->(c3) RETURN a;

हमारे परीक्षण डेटाबेस में कोई इंडेक्स नहीं मिला, इसलिए हम परीक्षण के लिए एक अलग तरीके से एक और डेटाबेस बनाएंगे। मुझे Neo4j में स्वतंत्र डेटा सेट (MySQL में डेटाबेस का एक एनालॉग) बनाने की क्षमता नहीं मिली। इसलिए, परीक्षण के लिए, मैंने सिर्फ Neo4j समुदाय (डेटाबेस स्थान) की सेटिंग में डेटा स्टोर का पथ परिवर्तित किया

Neo4j में उपयोग रिपॉजिटरी के लिए पथ को बदलकर किया जाता है

Neo4j में उपयोग रिपॉजिटरी के लिए पथ को बदलकर किया जाता है

चौकस पाठकों को test_fill_1.php कोड में टिप्पणियों के कुछ जोड़े मिल सकते हैं, अर्थात्

  $c = $neoClient->makeNode()->setProperty('criteriaId', $wareTemplateId * $criteriasCount + $criteriaId)->save(); // ->addLabels(array($neoCriteriaLabel)) -    commitBatch $neoCriterias->add($c, 'criteriaId', $wareTemplateId * $wareTemplatesCount + $criteriaId); // ->save()

Neo4jphp में बैच मोड में, मैं नोड्स में लेबल नहीं जोड़ सका और किसी कारणवश अनुक्रमणिका को सहेजा नहीं गया। यह देखते हुए कि Cypher मेरे लिए एक चीनी पत्र नहीं रह गया है, मैंने डेटाबेस को कट्टर - प्योर Cypher पर भरने का निर्णय लिया। तो यह test_fill_2.php निकला

 <?php use Everyman\Neo4j\Client, Everyman\Neo4j\Index\NodeIndex, Everyman\Neo4j\Relationship, Everyman\Neo4j\Node, Everyman\Neo4j\Cypher; require_once 'example_bootstrap.php'; $neoClient = new Client(); $wareTemplatesCount = 100; //    $criteriasCount = 50; //   $waresCount = 250; //   $minRelations = 20; //       $maxRelations = 40; //       if($maxRelations > $criteriasCount) { throw new \Exception("maxRelations[".$maxRelations."] should be bigger, that criteriasCount[".$criteriasCount."]"); } $query = new Cypher\Query($neoClient, "CREATE CONSTRAINT ON (n:Criteria) ASSERT n.criteriaId IS UNIQUE;", array()); $result = $query->getResultSet(); $query = new Cypher\Query($neoClient, "CREATE CONSTRAINT ON (n:Ware) ASSERT n.wareId IS UNIQUE;", array()); $result = $query->getResultSet(); for($wareTemplateId = 0;$wareTemplateId<$wareTemplatesCount;$wareTemplateId++) { $time = time(); $queryTemplate = "CREATE "; print $wareTemplateId." (".$criteriasCount." criterias, ".$waresCount." wares with rand(".$minRelations.",".$maxRelations.") ..."; $criterias = array(); for($criteriaId = 1;$criteriaId <=$criteriasCount;$criteriaId++) { //      (w1:Ware{wareId:1}) $cId = $criteriaId + $criteriasCount*$wareTemplateId; $queryTemplate .= "(c".$cId.":Criteria{criteriaId:".$cId."}), "; $criterias[] = $cId; } for($wareId = 1;$wareId <=$waresCount;$wareId++) { $wId = $wareId + $waresCount*$wareTemplateId; //      (w1:Ware{wareId:1}) $queryTemplate .= "(w".$wId.":Ware{wareId:".$wId."}), "; //       (w1)-[:SUIT]->(c1) $possibleLinks = array_merge(array(), $criterias); // clone $criterias   for($i = 1;$i<=rand($minRelations,$maxRelations);$i++) { $linkId = $possibleLinks[array_rand($possibleLinks)]; unset($possibleLinks[$linkId]); $queryTemplate .= "w".$wId."-[:SUIT]->c".$linkId.", "; } } $queryTemplate = substr($queryTemplate,0,-2); //   ", " $build = time(); $query = new Cypher\Query($neoClient, $queryTemplate, array()); // $queryTemplate    42   10000 , 500 , 200-400   - $result = $query->getResultSet(); print " Query build in ".($build - $time)." seconds, executed in ".(time() - $build)." seconds\n"; // die(); }

पहले अवतार में डेटा जोड़ने की गति अनुमानित रूप से अधिक थी।
30,000 नोड्स और 500,000 - 1,000,000 कनेक्शन के साथ परीक्षण स्क्रिप्ट ने साइबरफोर पर 140 सेकंड के लिए काम किया, डेटाबेस ने 62 मेगाबाइट डिस्क स्थान लिया। जब मैंने $ waresCount = 1000 (10,000 उत्पादों का उल्लेख नहीं करने के लिए) के साथ स्क्रिप्ट को चलाने की कोशिश की, तो मुझे "स्टैक ओवरफ़्लो त्रुटि" त्रुटि मिली। मैंने स्क्रिप्ट का उपयोग करके फिर से लिखा।

 MATCH (a {wareId: 1}), (b {criteriaId: 2}) MERGE (a)-[r:SUIT]->(b)

इससे गति में एक भयावह गिरावट आई, संशोधित स्क्रिप्ट ने लगभग एक घंटे तक काम किया। मैंने कई मानदंडों द्वारा नमूना गति का परीक्षण करने का निर्णय लिया और बाद में तेजी से डेटा प्रविष्टि के प्रश्न पर वापस लौटा।

 <?php use Everyman\Neo4j\Client, Everyman\Neo4j\Index\NodeIndex, Everyman\Neo4j\Relationship, Everyman\Neo4j\Node, Everyman\Neo4j\Cypher; require_once 'example_bootstrap.php'; $neoClient = new Client(); $time = microtime(); $query = new Cypher\Query($neoClient, "MATCH (a:Ware)-->(b:Criteria {criteriaId: 3}),(c:Criteria {criteriaId: 1}),(c2:Criteria {criteriaId: 2}) WHERE (a)-->(c) AND (a)-->(c2) RETURN a;", array()); $result = $query->getResultSet(); print "Done in ".(microtime() - $time)." seconds\n";

ऊपर की स्क्रिप्ट 0.02 सेकंड में काम करती है। सामान्य तौर पर, यह काफी स्वीकार्य है, लेकिन माल की संपत्तियों को अपडेट करते समय नोड्स के बीच बड़ी संख्या में कनेक्शन कैसे जल्दी से बनाए रखने की समस्या बनी हुई है।

वैकल्पिक समाधान

मैंने MySQL को रिपॉजिटरी के रूप में आज़माने के लिए "मेरी अंतरात्मा को साफ़ करने" का फैसला किया। अतिरिक्त जानकारी के बिना नोड्स के बीच लिंक एक अलग तालिका में संग्रहीत किए जाएंगे।

 CREATE TABLE IF NOT EXISTS `edges` ( `criteriaId` int(11) NOT NULL, `wareId` int(11) NOT NULL, UNIQUE KEY `criteriaId` (`criteriaId`,`wareId`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

नीचे दिए गए डेटाबेस को भरने के लिए टेस्ट स्क्रिप्ट

 <?php mysql_connect("localhost", "root", ""); mysql_select_db("test_nodes"); $wareTemplatesCount = 100; $criteriasCount = 50; $waresCount = 250; $minRelations = 20; $maxRelations = 40; $time = time(); for($wareTemplateId = 0;$wareTemplateId<$wareTemplatesCount;$wareTemplateId++) { $criterias = array(); for($criteriaId = 1;$criteriaId <=$criteriasCount;$criteriaId++) { $criterias[] = $wareTemplateId * $criteriasCount + $criteriaId; } for($wareId = 1;$wareId <=$waresCount;$wareId++) { $edges = array(); $wId = $wareTemplateId * $waresCount + $wareId; $links = array_rand($criterias,rand($minRelations,$maxRelations)); foreach($links as $linkId) { $edges[] = "(".$criterias[$linkId].",".$wareId.")"; } //        mysql_query("INSERT INTO edges VALUES ".implode(",",$edges)); } print "."; } print " [added ".$wareTemplatesCount." templates in ".(time() - $time)." sec]"; $time = time();

डेटाबेस को भरने में 12 सेकंड का समय लगा। तालिका का आकार 37 मेगाबाइट है। 2 मापदंड से खोज करने पर 0.0007 सेकंड लगते हैं

 SELECT e1.wareId FROM `edges` AS e1 JOIN edges AS e2 ON e1.wareId = e2.wareId WHERE e1.criteriaId =17 AND e2.criteriaId =31

एक और विकल्प

Mysql के तहत एक पूर्ण ग्राफ़ डेटा वेयरहाउस है - लेकिन मैंने इसका परीक्षण नहीं किया है। प्रलेखन द्वारा देखते हुए, यह Neo4j की तुलना में बहुत अधिक आदिम है।

निष्कर्ष

Neo4j एक बहुत ही शांत चीज है । Neo4j में "संगीतकारों द्वारा लिखे गए साउंडट्रैक जैसी फिल्मों में अभिनय करने वाले फिल्म अभिनेताओं को पसंद करने वाले उपयोगकर्ताओं के संपर्कों का चयन करने का अनुरोध" Neo4j में तुच्छ रूप से हल किया गया है। कुछ इस तरह

 MATCH (me:User {userId:123})-[:Like]->(musicants:User)-[:Author]->(s:Soundtrack)-[:Used]->(f:Film)<-[:Starred]-(actor: User)<-[:Like]-(u:User) RETURN u

SQL के लिए, यह बहुत अधिक परेशानी वाला काम है।

MySQL में नंगे सूचकांक तालिका के साथ पूर्ण ग्राफ़ डेटाबेस की तुलना करना गलत है, लेकिन मेरी समस्या के समाधान के भाग के रूप में, Neo4j का उपयोग करने से कोई लाभ नहीं हुआ ।

अद्यतन। चित्रों के यूआरएल को बदल दिया, सिद्धांत रूप में, उन्हें सभी को लोड किया जाना चाहिए।

अद्यतन २ । उन्होंने कई और विकल्प सुझाए - MongoDB, elasticsearch, solr, sphinx, OrientDB। मैं MongoDB परीक्षण करने की योजना बना रहा हूं, मैं परीक्षा परिणाम वहीं पर पोस्ट करूंगा।

Neo4j ग्राफ डेटाबेस के साथ आरंभ करना