TimesTen (XLA Application) में ट्रिगर

TimesTen PL / SQL (कार्यविधियाँ, फ़ंक्शंस, पैकेज आदि) का समर्थन करता है, लेकिन ट्रिगर के लिए कोई समर्थन नहीं है, क्योंकि ट्रिगर प्रदर्शन पर प्रतिकूल प्रभाव डालते हैं। लेकिन क्या होगा यदि आपको ट्रिगर तर्क को लागू करने की आवश्यकता है?

उत्तर एक XLA एप्लिकेशन लिखना है। आप C या Java, किसी को भी करीब से लिख सकते हैं।
नीचे मैं जावा का उपयोग करके एक उदाहरण का वर्णन करूंगा :)



जावा डेवलपर की गाइड कहती है:

"आप TimesTen की निगरानी के लिए TimesTen JMS / XLA API (JMS / XLA) का उपयोग कर सकते हैं
एक स्थानीय डेटा स्टोर में निर्दिष्ट तालिकाओं में परिवर्तन और इन परिवर्तनों की वास्तविक समय सूचना प्राप्त करते हैं। JMS / XLA का एक उद्देश्य ट्रिगर के लिए एक उच्च प्रदर्शन, अतुल्यकालिक विकल्प प्रदान करना है। "

यानी आप एक जावा एप्लिकेशन लिख सकते हैं जो TimesTen में परिवर्तन के बारे में संदेश (अतुल्यकालिक मोड में) प्राप्त करने के लिए JMS / XLA API का उपयोग कर सकता है। JMS / XLA, XLA परिवर्तनों को एक्सेस करने के लिए JMS प्रकाशन-सदस्यता इंटरफ़ेस का उपयोग करता है। आप यहाँ JMS (http://download.oracle.com/javaee/1.3/jms/tutorial) के बारे में अधिक पढ़ सकते हैं।

अगला, इस तरह के एक एप्लिकेशन बनाने का प्रयास करें।

प्रारंभ में, TimesTen में ऑब्जेक्ट बनाएं।
[oracle @ tt1 xla] $ ttisql dbxla

कॉपीराइट 1996-2010, ओरेकल। सभी अधिकार सुरक्षित।
टाइप करें? या "मदद" मदद के लिए, ttIsql छोड़ने के लिए "बाहर निकलें" टाइप करें।

connect "DSN=dbxla"; Connection successful: DSN=dbxla;UID=oracle;DataStore=/u01/app/oracle/datastore/dbxla;DatabaseCharacterSet=WE8MSWIN1252;ConnectionCharacterSet=US7ASCII;DRIVER=/u01/app/oracle/product/11.2.1/TimesTen/tt1/lib/libtten.so;PermSize=32;TempSize=50;TypeMode=0;PLSQL=0;CacheGridEnable=0; (Default setting AutoCommit=1) Command> CREATE USER oratt IDENTIFIED BY oracle; User created. Command> grant create session, create table, XLA to oratt; Command> connect "DSN=dbxla;UID=oratt;PWD=oracle;"; Connection successful: DSN=dbxla;UID=oratt;DataStore=/u01/app/oracle/datastore/dbxla;DatabaseCharacterSet=WE8MSWIN1252;ConnectionCharacterSet=US7ASCII;DRIVER=/u01/app/oracle/product/11.2.1/TimesTen/tt1/lib/libtten.so;PermSize=32;TempSize=50;TypeMode=0;PLSQL=0;CacheGridEnable=0; (Default setting AutoCommit=1) con1: Command> create table xlatest ( id NUMBER NOT NULL PRIMARY KEY, > name VARCHAR2(100) ); con1: Command> 

अब, एक बुकमार्क बनाएं। लेन-देन लॉग में पढ़ने की स्थिति को चिह्नित करने के लिए XLA बुकमार्क का उपयोग किया जाता है। इस बुलेट बुकमार्क का उपयोग xlatest तालिका में परिवर्तनों को ट्रैक करने के लिए करें।
con1: कमांड> कॉल ttXlaBookmarkCreate ('बुकमार्क');
con1: कमांड>

अगला, हम यह निर्धारित करते हैं कि हम किस तालिका में परिवर्तन करेंगे ऐसा करने के लिए, ttXlaSubscribe प्रक्रिया को कॉल करें। इस मामले में, हम बुकमार्क बुकमार्क का उपयोग करते हुए xlatest तालिका के साथ परिवर्तनों का निरीक्षण करेंगे।
con1: कमांड> कॉल ttXlaSubscribe ('xlatest', 'bookmark');
con1: कमांड>

इसके बाद, एप्लिकेशन सेट करने के लिए आगे बढ़ते हैं।
XLA से कनेक्ट करने के लिए, आपको JMS टॉपिक से कनेक्ट करने की आवश्यकता है, जो एक विशिष्ट TimesTen डेटाबेस से संबद्ध है। JMS / XLA कॉन्फ़िगरेशन फ़ाइल विषय नाम और डेटाबेस के बीच एक बाइंडिंग प्रदान करती है। डिफ़ॉल्ट रूप से, एप्लिकेशन दिए गए फ़ाइल के लिए खोज करता है, जिसे वर्तमान निर्देशिका में jmsxla.xml कहा जाता है, लेकिन यदि वांछित है, तो आप इस फ़ाइल के लिए एक अलग नाम और स्थान निर्धारित कर सकते हैं (प्रलेखन देखें)।

इस स्थिति में, मैं निम्नलिखित jmsxla.xml फ़ाइल का उपयोग करता हूं:

 <xlaconfig> <topics> <!-- topic for Xla demo --> <topic name="xlademo" connectionString="DSN=dbxla" xlaPrefetch="100" /> </topics> </xlaconfig> 

जैसा कि आप देख सकते हैं, मैंने xlademo विषय का नाम dbxla डेटाबेस से जोड़ा है।

अब सीधे java Applications लिखना शुरू करते हैं।
प्रारंभ में, संदर्भ को इनिशियलाइज़ करें।
हैशटेबल env = new Hashtable ();
env.put (Context.INITIAL_CONTEXT_FACTORY, "com.timesten.dataserver.jmsxla.SimpleInitialContextFactory");
इनिशियल कॉन्टेक्स्ट ic = new InitialContext (env);

अगला, XLA से कनेक्ट करने के लिए JMS कनेक्शन फ़ैक्टरी का उपयोग करें। उसके बाद, हम संदेश भेजने को सक्रिय करने के लिए कनेक्शन पर स्टार्ट () विधि कहते हैं। उसके बाद, इस कनेक्शन का उपयोग करके हम एक सत्र बनाते हैं।
निजी javax.jms.TopicConnection कनेक्शन; / ** जेएमएस कनेक्शन * /
निजी विषय सत्र; / ** जेएमएस सत्र * /
...
TopicConnectionFactory connectionFactory = (TopicConnectionFactory) ic.lookup ("टॉपिककॉन्फेक्शनफैक्टरी");
कनेक्शन = connectionFactory.createTopicConnection ();
...
// सत्र प्राप्त करें
session = connection.createTopicSession (गलत, सत्र। AUTO_ACKNOWLEDGE);
...

साथ ही, एक सत्र बनाते समय, आपको सत्र की लेनदेन प्रकृति और पावती मोड के प्रकार को निर्दिष्ट करना होगा।
JMS / XLA तीन मॉडल (AUTO_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE) का समर्थन करता है, मॉडल के बारे में और अधिक जानकारी प्रलेखन में मिल सकती है। उदाहरण में, मैं पहले मॉडल का उपयोग करता हूं और सत्र की लेन-देन को गलत पर सेट करता हूं।

इसके बाद, आपको संदेश प्राप्त करने के तरीके पर निर्णय लेना होगा। दो विकल्प संभव हैं: सिंक्रोनस और एसिंक्रोनस।

तुल्यकालिक संस्करण में, संदेश क्रमिक रूप से संसाधित होते हैं (एक के बाद एक)। इसका मतलब यह है कि जबकि संदेश संसाधित नहीं हुआ है, एक और प्रतीक्षा कर रहा है।
एक सिंक्रोनस वेरिएंट के लिए, हम कनेक्शन पर स्टार्ट () विधि को कॉल करते हैं, संदेश भेजने के लिए सक्रिय करते हैं, एक विषय बनाते हैं, फिर एक सब्सक्राइबर बनाते हैं और प्राप्त () और getNoWait () विधियों का उपयोग करके संदेश प्राप्त करते हैं।

 connection.start(); Topic topic = session.createTopic(topicName); TopicSubscriber subscriber = session.createDurableSubscriber(topic, bookmark); .. MapMessage message = (MapMessage)subscriber.receive(); ... 

एसिंक्रोनस मोड में, आपको एक श्रोता बनाने और उसमें संदेशों को संसाधित करने की आवश्यकता होती है।
MyListener myListener = नया MyListener (आउटस्ट्रीम);

विषय xlaTopic = session.createTopic (विषय);
TopicSubscriber ग्राहक = session.createDurableSubscriber (xlaTopic, बुकमार्क);
...
सब्स्क्राइबर.सेटमैसेज लिस्टनर (माय लिस्टनर);
कनेक्शन.स्टार्ट ();
...

निम्नलिखित एक वर्ग का एक उदाहरण है जो तुल्यकालिक मोड को लागू करता है (फ़ाइल DemoXLA.java)।
आयात java.util.numeration;
आयात java.util.Hashtable;
आयात javax.jms.JMSException;
आयात javax.jms.apMessage;
आयात javax.jms.Session;
आयात javax.jms.Topic;
आयात javax.jms.TopicConnectionFactory;
आयात javax.jms.TopicConnection;
आयात javax.jms.TopicSession;
आयात javax.jms.TopicSubscriber;
आयात javax.naming.Context;
आयात javax.naming.InitialContext;
आयात javax.naming.NamingException;

 public class DemoXLA { private TopicConnectionFactory connectionFactory; private TopicConnection connection; private TopicSession session; private Topic topic; private TopicSubscriber subscriber; public DemoXLA( String cf, String topicName, String selector) throws JMSException, NamingException {String key; Context messaging = getInitialContext(); // getting the context connectionFactory = (TopicConnectionFactory)messaging.lookup(cf); connection = connectionFactory.createTopicConnection(); connection.start(); session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); topic = session.createTopic(topicName); subscriber = session.createDurableSubscriber(topic, selector); int i=0; while (i<10) { MapMessage message = (MapMessage)subscriber.receive(); Enumeration e = message.getMapNames(); while (e.hasMoreElements()) { key = (String)e.nextElement(); System.out.println("[ " + key + " = " + message.getObject(key) + " ]"); } System.out.println("----------------------------------------"); } session.unsubscribe(selector); subscriber.close(); session.close(); connection.stop(); } private Context getInitialContext() throws NamingException { Hashtable env = new Hashtable(); env.put(Context.INITIAL_CONTEXT_FACTORY, "com.timesten.dataserver.jmsxla.SimpleInitialContextFactory"); InitialContext initialContext = new InitialContext(env); return initialContext; } public static void main(String[] args) throws JMSException, NamingException { DemoXLA demo = new DemoXLA("TopicConnectionFactory", "Level2Demo", "bookmark"); } } 

निम्नलिखित उन वर्गों का एक उदाहरण है जो अतुल्यकालिक मोड (MyListener.java, DemoXLA2.java) को लागू करते हैं।

MyListener.java
आयात java.util.numeration;
आयात javax.jms.JMSException;
आयात javax.jms.apMessage;
आयात javax.jms.Message;
आयात javax.jms.MessageListener;

 public class MyListener implements MessageListener { public MyListener() {} public void onMessage(Message message) { MapMessage mp = (MapMessage)message; Enumeration e; try { e = mp.getMapNames(); } catch (JMSException s) { e = null; System.out.println("error 1"); } while (e.hasMoreElements()) { String key = (String)e.nextElement(); try { System.out.println("[ " + key + " = " + mp.getObject(key) + " ]"); } catch (JMSException f) { System.out.println("error 2"); } } System.out.println("----------------------------------------"); } } 

DemoXLA2.java
आयात java.util.Hashtable;
आयात javax.jms.JMSException;
आयात javax.jms.Session;
आयात javax.jms.Topic;
आयात javax.jms.TopicConnectionFactory;
आयात javax.jms.TopicSession;
आयात javax.jms.TopicSubscriber;
आयात javax.naming.Context;
आयात javax.naming.InitialContext;
आयात javax.naming.NamingException;

 public class DemoXLA2 { private javax.jms.TopicConnectionFactory connectionFactory; private javax.jms.TopicConnection connection; private TopicSession session; private Topic topic; private TopicSubscriber subscriber; public DemoXLA2( String cf, String topicName, String selector) throws JMSException, NamingException, InterruptedException { Context messaging = getInitialContext(); Object connectionFactoryObject = messaging.lookup(cf); connectionFactory = (TopicConnectionFactory)connectionFactoryObject; connection = connectionFactory.createTopicConnection(); MyListener myListener = new MyListener(); session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); topic = session.createTopic(topicName); subscriber = session.createDurableSubscriber(topic, selector); subscriber.setMessageListener(myListener); connection.start(); Thread.sleep(60000); session.unsubscribe(selector); subscriber.close(); session.close(); connection.stop(); } private Context getInitialContext() throws NamingException { Hashtable env = new Hashtable(); env.put(Context.INITIAL_CONTEXT_FACTORY, "com.timesten.dataserver.jmsxla.SimpleInitialContextFactory"); InitialContext initialContext = new InitialContext(env); return initialContext; } public static void main(String[] args) throws JMSException, NamingException, InterruptedException { DemoXLA2 demo = new DemoXLA2("TopicConnectionFactory", "xlademo", "bookmark"); } } 

अगला, किसी भी उदाहरण को चलाएं और xlatest तालिका से डेटा बनाने, बदलने और हटाने का प्रयास करें।

 Command> insert into xlatest values (2, 'w'); 1 row inserted. Command> update xlatest set name = 'test' where id=2; 1 row updated. Command> delete from xlatest; 1 row deleted. Command> 

तदनुसार, हमें प्राप्त होने वाले आवेदन में:

 [ __TYPE = 10 ] [ __COMMIT = true ] [ __FIRST = true ] [ __NULLS = ] [ __TBLNAME = XLATEST ] [ __TBLOWNER = ORATT ] [ __mver = 5621355056449191939 ] [ __mtyp = null ] [ ID = 2 ] [ NAME = w ] ---------------------------------------- [ __TYPE = 11 ] [ __COMMIT = true ] [ __FIRST = true ] [ __UPDCOLS = NAME ] [ __NULLS = ] [ __TBLNAME = XLATEST ] [ __TBLOWNER = ORATT ] [ __mver = 5621355056449191942 ] [ __mtyp = null ] [ _ID = 2 ] [ ID = 2 ] [ _NAME = w ] [ NAME = test ] ---------------------------------------- [ __TYPE = 12 ] [ __COMMIT = true ] [ __FIRST = true ] [ __NULLS = ] [ __TBLNAME = XLATEST ] [ __TBLOWNER = ORATT ] [ __mver = 5621355056449191945 ] [ __mtyp = D ] [ ID = 2 ] [ NAME = test ] ---------------------------------------- 

जैसा कि आप देख सकते हैं, हमें xlatest तालिका के साथ संचालन के बारे में संदेश प्राप्त हुए।
संदेशों में निम्नलिखित प्रारूप हैं:
सिस्टम विशेषताएँ एक डबल अंडरस्कोर के साथ शुरू होती हैं, उदाहरण के लिए:
__TYPE - ऑपरेशन का प्रकार (इन्सर्ट (10), अपडेट (11), डिलीट (12)) अन्य प्रकार भी संभव हैं (प्रलेखन देखें)। ऑपरेशन के प्रकार को निर्धारित करने के लिए स्थिरांक हैं।
__COMMIT - लेनदेन के पूरा होने का संकेत देता है (यदि सच है)।
__FIRST - लेन-देन में पहला ऑपरेशन का संकेत देता है (यदि सच है)।
__TBLNAME - तालिका का नाम
__TBLOWNER - तालिका का स्वामी
__NULLS - संकेत विशेषताएँ जिनमें एक शून्य मान होता है
__mver और __mtyp सिस्टम गुण हैं।
आदि (प्रलेखन देखें)
अंडरस्कोर के बिना विशेषताएँ - टेबल कॉलम जिसमें विशिष्ट मूल्य हैं, उदाहरण के लिए:
[आईडी = २]
[NAME = परीक्षण]
उदाहरण के लिए, एक अंडरस्कोर के साथ शुरू होने वाले गुण - पुराने फ़ील्ड मान (अपडेट ऑपरेशन के दौरान प्रकट)
[_ID = 2]
[आईडी = २]
[_NAME = w]
[NAME = परीक्षण]

परिणाम
इसलिए, जावा के बारे में काफी सतही ज्ञान होने पर, आप एक XLA एप्लिकेशन लिख सकते हैं जो TimesTen से प्राप्त विभिन्न संदेशों को संसाधित कर सकता है। इसके अलावा, XLA एप्लिकेशन अतुल्यकालिक मोड में चलता है, जिसका लगभग Oracle TimesTen के प्रदर्शन पर कोई प्रभाव नहीं पड़ता है।

लेख लेखक: गेन्नेदी सिगालाव