Teiid भाग 1 के लिए नए डेटा स्रोत: DDL का उपयोग करना

जिन लोगों को कई डेटा स्रोतों को संयोजित करने की आवश्यकता का सामना करना पड़ा, वे शायद पहले से ही JBoss Teiid के बारे में जानते हैं, इस बारे में परिचयात्मक लेख हब पर है संक्षेप में, इस प्रणाली को कई भौतिक डेटा स्रोतों (उदाहरण के लिए, एक DBMS) को SQL एक्सेस के साथ सिंगल वर्चुअल डेटाबेस (VDB) के रूप में प्रस्तुत करने के लिए डिज़ाइन किया गया है।

Teiid मूल रूप से कई डेटा स्रोतों का समर्थन करता है, उदाहरण के लिए, Oracle , DB2 , M $ SQL सर्वर , MySQL , PostgreSQL , SalesForce , लेकिन साथ ही यह वेब सेवाओं, XML, JSON के साथ काम करने के लिए सुविधाजनक उपकरण भी प्रदान करता है। इस टूलकिट के आधार पर, आप आसानी से एक सरल डेटा स्रोत तक पहुंच बना सकते हैं (उदाहरण के लिए, ट्विटर पर अनुरोध करें, डिलीवरी में Teiid का एक तैयार उदाहरण है), और आप केवल DDL विवरण के साथ ऐसा कर सकते हैं। लेकिन कुछ अधिक जटिल के लिए, आपको पहले से ही कोड लिखना होगा।

लेख का दूसरा भाग ।

इस भाग में, हम DDL का उपयोग करते हुए एक विवरण विधि पर विचार करेंगे, अगले में हम एक अनुवादक लिखेंगे।

सामान्य तौर पर, स्रोत तक पहुंच को व्यवस्थित करने के लिए दो घटकों की आवश्यकता होती है: एक कनेक्टर और एक अनुवादक। कनेक्टर स्वयं कनेक्शन के लिए जिम्मेदार है, जबकि अनुवादक स्रोत डेटा (अनुरोध) को एकत्र करता है, इसे कनेक्टर द्वारा प्रदान किए गए कनेक्शन के माध्यम से भेजता है, एक प्रतिक्रिया प्राप्त करता है, और इसे एक टीईड-फ्रेंडली रूप में परिवर्तित करता है।

परंपरागत रूप से, यह वर्णन करने के लिए कि हाबर के पदों में क्या वर्णित है, लेखक हैबर से संबंधित किसी चीज़ का उपयोग करते हैं। क्यों नहीं? डेटा स्रोत के रूप में, हम Habr-api: http://habrahabr.ru/api/profile/%name% लेते हैं।

Teiid के साथ आने वाले अन्य कनेक्टर्स में, एक सार्वभौमिक WS कनेक्टर है जो किसी भी सेवा के लिए उपयुक्त है जो http / https एक्सेस प्रदान करता है। हम इसका उपयोग किसी हैबर की वेब-सेवा तक पहुंच के लिए करेंगे।

मूल सेटिंग्स

सबसे पहले आपको एक डेटा स्रोत पंजीकृत करने की आवश्यकता है। JBoss 7 के लिए, आपको इसे % JBOSS_HOME% / स्टैंडअलोन / कॉन्फ़िगरेशन / स्टैंडअलोन.xml फ़ाइल (या ... डोमेन ... ) में जोड़ना होगा:

<subsystem xmlns="urn:jboss:domain:resource-adapters:1.0"> [...] <resource-adapters> <resource-adapter> <archive>teiid-connector-ws.rar</archive> <transaction-support>NoTransaction</transaction-support> <connection-definitions> <connection-definition class-name="org.teiid.resource.adapter.ws.WSManagedConnectionFactory" jndi-name="java:/habrDS" enabled="true" use-java-context="true" pool-name="habr-ds"><!-- [1] --> <config-property name="EndPoint">http://habrahabr.ru/api/profile/</config-property><!-- [2] --> </connection-definition> </connection-definitions> </resource-adapter> </resource-adapters> [...] 

2 महत्वपूर्ण बिंदु हैं: निशान के साथ लाइन में [1] हमने अपने डेटा स्रोत का जेएनडीआई नाम निर्धारित किया है (हम भविष्य में इस नाम का उपयोग करेंगे), और निशान के साथ लाइन में [2] - अंतिम बिंदु - हमारी सेवा का URL।

डीडीएल लिखना

मैंने पहले ही ट्विटर पर अनुरोधों के कार्यान्वयन के एक उदाहरण के बारे में ऊपर उल्लेख किया है, जो तीइद के साथ आता है। उसी तरह से हबर-आपी तक पहुँचने के लिए, VDB फ़ाइल में सही DDL लिखना पर्याप्त है।

तो habr-vdb.xml :

 <?xml version="1.0" encoding="UTF-8" standalone="yes"?> <vdb name="habr" version="1"> <model name="habr"> <source name="habr" translator-name="rest" connection-jndi-name="java:/habrDS"/> </model> <model name="habrview" type="VIRTUAL"> <metadata type="DDL"><![CDATA[ CREATE VIRTUAL PROCEDURE getHabr(name varchar) RETURNS (login varchar(128), karma float, rating float, ratingposition long) AS select ha.* from (call habr.invokeHTTP(action => 'GET', endpoint =>querystring(name))) w, XMLTABLE('habrauser' passing XMLPARSE(document w.result) columns login varchar(128) PATH 'login', karma float PATH 'karma', rating float PATH 'rating', ratingposition long PATH 'ratingPosition') ha; CREATE VIEW Habr AS select * FROM habrview.getHabr; ]]> </metadata> </model> <translator name="rest" type="ws"> <property name="DefaultBinding" value="HTTP"/> <property name="DefaultServiceMode" value="MESSAGE"/> </translator> </vdb> 

वास्तव में, यह हमारे डेटा स्रोत का एक तैयार-निर्मित कार्यान्वयन है, क्योंकि किसी भी उपयोगकर्ता के बारे में Habr-api के माध्यम से जानकारी प्राप्त करने के लिए पर्याप्त लिखा गया है।

कोड को अधिक विवरण में पार्स करें

/> - वंशानुक्रम के माध्यम से एक नए अनुवादक का वर्णन करने का एक तरीका (प्रकार - मूल अनुवादक का नाम, नाम - निर्मित अनुवादक का नाम)। इस विधि का इरादा है ताकि आप डिफ़ॉल्ट मानों के अलावा अन्य गुणों का मान सेट कर सकें। क्योंकि संपत्ति का डिफ़ॉल्ट मान DefaultBinding = SOAP12 , तो हम सीधे ws अनुवादक का उपयोग नहीं कर सकते हैं।

नियमित WS कनेक्टर इनवोकएचटीपी () प्रक्रिया को लागू करता है, जिसके माध्यम से इसकी सभी कार्यक्षमता काम करती है। /> हमारे habrDS डेटा स्रोत को जोड़ने का कार्य करता है (हमने इसे स्वसंपूर्ण। xml में ऊपर वर्णित किया है) और नव निर्मित ' बाकी ' अनुवादक। इस प्रकार, जब habr.invokeHTTP() कहा जाता है, तो हम अनुवादक को विशिष्ट मापदंडों और वेब सेवा के दिए गए URL के साथ कहते हैं।

प्रत्यक्ष डेटा प्रसंस्करण के लिए, हमें एक अतिरिक्त मॉडल बनाना होगा - /> : तथ्य यह है कि हम केवल DDL के माध्यम से डेटाबेस संस्थाओं का वर्णन कर सकते हैं जिसमें type="VIRTUAL" वाले मॉडल हैं, दूसरी ओर, हम केवल गैर में डेटा स्रोत और अनुवादक निर्दिष्ट कर सकते हैं -विशिष्ट मॉडल, और हम दोनों की जरूरत है।

यहां सब कुछ सरल है: हम एक वर्चुअल प्रक्रिया getHabr , जिसके लिए हम इनपुट पैरामीटर और परिणामों का वर्णन करते हैं, और जिसे एक SELECT अनुरोध के माध्यम से कार्यान्वित किया जाता है, जो बदले में, वेब सेवा को GET अनुरोध निष्पादित करने के लिए habr.invokeHTTP() को कॉल habr.invokeHTTP() परिणाम के उद्देश्य से) एलियास w )। यहां name पैरामीटर को आभासी प्रक्रिया से वास्तविक एक तक पारित किया जाता है। habr.invokeHTTP() परिणाम पैरामीटर में प्राप्त डेटा को लौटाता है, जिसे तब XMLPARSE(document w.result) बिल्ट-इन फंक्शन XMLPARSE(document w.result) , जहाँ document मतलब है कि यह अच्छी तरह से गठित XML है, न कि एक टुकड़ा। यह फ़ंक्शन प्राप्त डेटा को पार्स करता है और पहले से ही इसे XML ट्री के रूप में, XMLTABLE फ़ंक्शन के लिए XMLTABLE करता है, जिसके लिए हम, साथ ही साथ वर्चुअल प्रक्रिया के लिए, प्रकारों को इंगित करने वाले कॉलम की एक सूची निर्दिष्ट करते हैं, और प्रकारों के अलावा, उन रास्तों को निर्दिष्ट करते हैं जिनके साथ मान होंगे एक XML दस्तावेज़ से प्राप्त करें। 'habrauser' अर्थ है आधार पथ।

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

वह सब है। बाकी केवल एक अनुरोध करने के लिए है:

 select * from habrview.habr where name='elfuegobiz'