TimesTenはPL / SQL（プロシージャ、関数、パッケージなど）をサポートしていますが、トリガーはサポートされていません。 トリガーはパフォーマンスに悪影響を及ぼします。 しかし、トリガーロジックを実装する必要がある場合はどうでしょうか。
答えは、XLAアプリケーションを作成することです。 誰でも、CまたはJavaで書くことができます。
以下では、javaを使用した例を説明します:)
Java開発者ガイドによると：
「TimesTen JMS / XLA API（JMS / XLA）を使用して、TimesTenを監視できます。
ローカルデータストア内の指定されたテーブルを変更し、これらの変更のリアルタイム通知を受け取ります。 JMS / XLAの目的の1つは、トリガーに代わる高性能で非同期の代替手段を提供することです。
つまり JMS / XLA APIを使用してTimesTenの変更に関するメッセージを（非同期モードで）受信できるJavaアプリケーションを作成できます。 JMS / XLAは、JMSパブリッシュ/サブスクライブインターフェイスを使用して、XLAの変更にアクセスします。 JMSの詳細については、こちら（http://download.oracle.com/javaee/1.3/jms/tutorial）を参照してください。
次に、そのようなアプリケーションを作成してみてください。
最初に、TimesTenでオブジェクトを作成します。
[oracle @ tt1 xla] $ ttisql dbxla
著作権1996-2010、Oracle。 無断複写・転載を禁じます。
タイプ？ またはヘルプを表示するには「help」、「exit」と入力して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：Command> call ttXlaBookmarkCreate（ 'bookmark'）;
con1：コマンド>
次に、観察するテーブルの変更を決定します。 これを行うには、ttXlaSubscribeプロシージャを呼び出します。 この場合、ブックマークブックマークを使用してxlatestテーブルの変更を観察します。
con1：Command> call ttXlaSubscribe（ 'xlatest'、 'bookmark'）;
con1：コマンド>
次に、アプリケーションのセットアップに進みましょう。
XLAに接続するには、特定のTimesTenデータベースに関連付けられているJMSトピックに接続する必要があります。 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アプリケーションを直接作成しましょう。
最初に、コンテキストを初期化します。
Hashtable env = new Hashtable（）;
env.put（Context.INITIAL_CONTEXT_FACTORY、 "com.timesten.dataserver.jmsxla.SimpleInitialContextFactory"）;
InitialContext ic = new InitialContext（env）;
次に、JMS接続ファクトリーを使用してXLAに接続します。 その後、接続でstart（）メソッドを呼び出して、メッセージの送信を有効にします。 その後、この接続を使用してセッションを作成します。
プライベートjavax.jms.TopicConnection接続。 / ** JMS接続* /
プライベートTopicSessionセッション。 / ** JMSセッション* /
...
TopicConnectionFactory connectionFactory =（TopicConnectionFactory）ic.lookup（ "TopicConnectionFactory"）;
connection = connectionFactory.createTopicConnection（）;
...
//セッションを取得します
session = connection.createTopicSession（false、Session.AUTO_ACKNOWLEDGE）;
...
また、セッションを作成するときは、セッションのトランザクションの性質と確認応答モードのタイプを指定する必要があります。
JMS / XLAは3つのモデル（AUTO_ACKNOWLEDGE、DUPS_OK_ACKNOWLEDGE、CLIENT_ACKNOWLEDGE）をサポートしています。モデルの詳細については、ドキュメントをご覧ください。 この例では、最初のモデルを使用し、セッションのトランザクション性をfalseに設定します。
次に、メッセージの受信モードを決定する必要があります。 同期と非同期の2つのオプションが可能です。
同期バージョンでは、メッセージは順番に処理されます（順番に処理されます）。 これは、メッセージが処理されていない間、別のものが待機していることを意味します。
同期バリアントの場合、接続でstart（）メソッドを呼び出して、メッセージの送信をアクティブにし、トピックを作成してから、サブスクライバーを作成し、receive（）およびreceiveNoWait（）メソッドを使用してメッセージを受信します。
connection.start(); Topic topic = session.createTopic(topicName); TopicSubscriber subscriber = session.createDurableSubscriber(topic, bookmark); .. MapMessage message = (MapMessage)subscriber.receive(); ...
非同期モードでは、リスナーを作成してメッセージを処理する必要があります。
MyListener myListener = new MyListener（outStream）;
トピックxlaTopic = session.createTopic（トピック）;
TopicSubscriber subscriber = session.createDurableSubscriber（xlaTopic、bookmark）;
...
subscriber.setMessageListener（myListener）;
connection.start（）;
...
以下は、同期モード（ファイルDemoXLA.java）を実装するクラスの例です。
import java.util.Enumeration;
import java.util.Hashtable;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Session;
import javax.jms.Topic;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicConnection;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.naming.Context;
import javax.naming.InitialContext;
import 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();
以下は、非同期モード（MyListener.java、DemoXLA2.java）を実装するクラスの例です。
Mylistener.java
import java.util.Enumeration;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import 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
import java.util.Hashtable;
import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.Topic;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.naming.Context;
import javax.naming.InitialContext;
import 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-トランザクションの完了を通知します（trueの場合）。
__FIRST-トランザクションの最初の操作を通知します（trueの場合）。
__TBLNAME-テーブル名
__TBLOWNER-テーブルの所有者
__NULLS-NULL値を含む属性を通知します
__mverおよび__mtypはシステム属性です。
など （ドキュメントを参照）
アンダースコアなしの属性-特定の値を持つテーブル列、たとえば：
[ID = 2]
[NAME =テスト]
1つのアンダースコアで始まる属性-古いフィールド値（更新操作中に表示されます）。例：
[_ID = 2]
[ID = 2]
[_NAME = w]
[NAME =テスト]
まとめ
したがって、Javaのかなり表面的な知識を持っている場合、TimesTenから受信した様々なメッセージを処理できるXLAアプリケーションを作成できます。 さらに、XLAアプリケーションは非同期モードで実行されますが、これはOracle TimesTenのパフォーマンスにはほとんど影響しません。
記事の著者：Gennady Sigalaev