Transactd チュートリアル

C++用クライアントは、使用するコンパイラがLinuxのgccもしくはWindowsのVisual Studio 2010であれば、ビルド済みバイナリをインストールすることができます。 Linuxはx86-64Bit 、Windowsはx86-32Bit/64Bitの両方があります。LinuxはLSBに基づいた Genericなバイナリです。

それ以外のコンパイラの場合はソースコードからクライアントライブラリをビルドします。

詳しいインストール方法はインストールガイドを参照してください。

ビルド済みのCOMコンポーネントをインストールすることができます。

COMコンポーネントはWindows用のx86-32Bit/64Bitの両方が用意されています。

詳しいインストール方法はインストールガイドを参照してください。

Ruby用クライアントは、RubyGemsのパッケージとしてインストールすることができます。

詳しいインストール方法はインストールガイドを参照してください。

Linuxではソースコードからクライアントライブラリをビルドします。

詳しいインストール方法はインストールガイドを参照してください。

Windowsの場合、お使いのPHPに合わせてビルド済みバイナリをインストールすることができます。

ビルド済みのCOMコンポーネントをインストールすることができます。

COMコンポーネントはWindows用のx86-32Bit/64Bitの両方が用意されています。

詳しいインストール方法はインストールガイドを参照してください。

C++のプログラムをビルドする際に、Transactdのヘッダーファイルをincludeしライブラリファイルをリンクできるよう、以下のディレクトリを設定します。

Windowsの場合

• TransactdのソースコードパッケージもしくはSDKのsourceディレクトリをincludeパスに加える。
  （例：C:\transactd-client-win64_with_sdk-2.4.3\source）
• BOOSTのパスをincludeパスに加える。
  （例：C:\boost\boost_1_58_0）
• tdclcpp_xxx_xx_xxx.libとリンクするために、SDKまたはビルドディレクトリのlibディレクトリを libraryパスに加える。
  （例：C:\transactd-client-win64_with_sdk-2.4.3\lib）
• tdclcpp_xxx_xx_xxx.libをリンクするようプロジェクトに加えるか、 Visual Studio および Embarcadero C++ Builder を使用している場合、プロジェクトのプロパティでプリプロセッサに TRDCL_AUTOLINKを設定する。

Linuxの場合

• TransactdのソースコードパッケージもしくはSDKのsourceディレクトリをincludeパスに加える。
  （例：~/transactd-client-linux-x86_64_with_sdk-2.4.3/source）
• 同様にsource/linuxディレクトリもincludeパスに加える。
  （例：~/transactd-client-linux-x86_64_with_sdk-2.4.3/source/linux）
• BOOSTのパスをincludeパスに加える。
  （例：~/boost/boost_1_58_0）
• libtdclcpp_64m.so.2.4がインストールされているディレクトリをlibraryパスに加え、 tdclcpp_64mをリンクするようにMakefileを作成する。Makefileの例

JScriptのプログラムは、コンパイルする必要はありません。

Rubyのプログラムは、コンパイルする必要はありません。

PHPのプログラムは、コンパイルする必要はありません。

Visual Studioの[プロジェクト]メニューから[参照の追加]を選択し、[参照マネージャー]を開きます。[COM]のリストから transactdをチェックし、参照に追加します。

参照に追加すると[オブジェクトブラウザ]で、Transactdクライアントのすべての定数、関数、クラスの定義が確認できます。 それらの正しい名前を知りたいときは、これで確認すると便利です。

SDKに含まれるヘッダーファイルとサンプルで使用する標準ライブラリのヘッダーを#includeします。

#include <bzs/db/protocol/tdap/client/database.h>
#include <bzs/db/protocol/tdap/client/table.h>
#include <stdio.h>

Transactdクライアントの名前空間を省略できるようにusing namespace宣言します。

using namespace bzs::db::protocol::tdap::client;
using namespace bzs::db::protocol::tdap;

JScriptでTransactdクライアントを使用する際には、requireやincludeのような記述は不要です。各クラスのインスタンスはnew ActiveXObjectで生成します。

var db = new ActiveXObject('transactd.database');

RubyGemsとしてインストールしたTransactdクライアントは、通常のgemと同様にrequireして使用できます。

require 'transactd'

PHPでは、transactd.phpをinclude_pathに設定されたフォルダに配置してrequireにファイル名を指定するか、requireに直接transactd.phpのパスを指定する必要があります。 transactd.phpには、Transactdクライアントの定数定義や、より便利に使用するためのArrayAccessインターフェースの実装などが含まれています。

各種クラスが配置されている名前空間はBizStation\Transactdです。使用するクラスを事前にuse宣言します。

require('transactd.php');
use BizStation\Transactd\Transactd;
use BizStation\Transactd\Database;
use BizStation\Transactd\ActiveTable;
use BizStation\Transactd\Query;
use BizStation\Transactd\SortFields;
use BizStation\Transactd\GroupQuery;
use BizStation\Transactd\Count;
use BizStation\Transactd\RecordsetQuery;
use BizStation\Transactd\Tabledef;

transactd.phpにはTransactdクライアントのすべての定数、関数、クラスが定義されています。 また、引数と戻り値のPHPDocコメントが付けられています。PHPDocに対応するエディタであればコード補完が行えます。 そうでない場合は、このファイルを検索すると便利です。

Transactdクライアントの名前空間を省略できるようにusing宣言します。

using transactd;

static const _TCHAR* uri = _T("tdap://localhost/tdtutorial?dbfile=transactd_schema");
database* db = database::create();
db->open(uri, TYPE_SCHEMA_BDF, TD_OPEN_NORMAL);
// ...
// close and release database object
database::destroy(db);

var TYPE_BDF = 0;
var OPEN_NORMAL = 0;
var URI = 'tdap://localhost/tdtutorial?dbfile=transactd_schema';
// open database
var db = new ActiveXObject('transactd.database');
db.Open(URI, TYPE_BDF, OPEN_NORMAL);
// ...
// close database
db.Close();

databaseオブジェクトのメモリの解放はCOMによって自動で行われます。 メモリ解放時にデータベースも閉じられますが、明示的にcloseを呼び出すようにしましょう。

uri = 'tdap://localhost/tdtutorial?dbfile=transactd_schema'
# open database
db = Transactd::Database.new()
db.open(uri, Transactd::TYPE_SCHEMA_BDF, Transactd::TD_OPEN_NORMAL)
# ...
# close database
db.close()

databaseオブジェクトのメモリの解放はRubyのGCによって自動で行われます。 メモリ解放時にデータベースも閉じられますが、明示的にcloseを呼び出すようにしましょう。

$uri = 'tdap://localhost/tdtutorial?dbfile=transactd_schema';
// open database
$db = new Database();
$db->open($uri, Transactd::TYPE_SCHEMA_BDF, Transactd::TD_OPEN_NORMAL);
// ...
// close database
$db->close();

databaseオブジェクトのメモリの解放はPHPのGCによって自動で行われます。 メモリ解放時にデータベースも閉じられますが、明示的にcloseを呼び出すようにしましょう。

const string uri = "tdap://localhost/tdtutorial?dbfile=transactd_schema";
// open database
Database db = new Database();
db.Open(uri, eSchemaType.schemaBdf, eOpenMode.normal);
// ...
// close database
db.Close();

databaseオブジェクトのメモリの解放はCOMによって自動で行われます。 メモリ解放時にデータベースも閉じられますが、明示的にcloseを呼び出すようにしましょう。

// ...
// open table
table* tb = db->openTable(_T("users"), TD_OPEN_NORMAL);
// ...
// release table
tb->release();
// ...
// close and release database object
database::destroy(db);

// ...
// open table
var tb = db.OpenTable('users', OPEN_NORMAL);
// ...
// close table
tb.Close();
// ...
// close database
db.Close();

# ...
# open table
tb = db.openTable('users', Transactd::TD_OPEN_NORMAL)
# ...
# close table
tb.close()
# ...
# close database
db.close()

// ...
// open table
$tb = $db->openTable('users', Transactd::TD_OPEN_NORMAL);
// ...
// close table
$tb->close();
// ...
// close database
$db->close();

// ...
// open table
Table tb = db.OpenTable("users", eOpenMode.normal);
// ...
// close table
tb.Close();
// ...
// close database
db.Close();

// read a record
tb->setKeyNum(0);
tb->clearBuffer();
tb->setFV(_T("id"), 2);
tb->seek();
if (tb->stat() == 0)
  _tprintf(_T("id = 2, name = %s\n"), tb->getFVstr(_T("name")));
else
  _tprintf(_T("Can not read id = 2"));

• 値のセットはsetFVです。最初のパラメータがフィールド名、2番目が値です。値の型は_TCHAR* int64 int short double float などのオーバーロード関数が用意されています。
• 値の取出しはgetFVxxxです。xxxの部分は取出す型に応じてgetFVint getFV64 getFVstr getFVdbl getFVbinなどが用意されています。

// read a record
tb.KeyNum = 0;
tb.ClearBuffer();
tb.Vlng('id') = 2;
tb.Seek();
if (tb.Stat == 0)
  WScript.Echo('id = 2, name = ' + tb.Text('name'));
else
  WScript.Echo('Can not read id = 2');

• 型に応じて用意されたV64Vlng Vbin Text などの引数付きプロパティを使用して、値をセットもしくは取得します。

# read a record
tb.setKeyNum(0)
tb.clearBuffer()
tb.setFV('id', 2)
tb.seek()
if (tb.stat() == 0)
  puts('id = 2, name = ' + tb.getFVstr('name'))
else
  puts('Can not read id = 2')
end

• 値のセットはsetFVです。最初のパラメータがフィールド名、2番目が値です。
• 値の取出しはgetFVxxxです。xxxの部分は取出す型に応じてgetFVint getFVstr getFVbin などが用意されています。

// read a record
$tb->setKeyNum(0);
$tb->clearBuffer();
$tb->setFV('id', 2);
$tb->seek();
if ($tb->stat() == 0)
  echo('id = 2, name = ' . $tb->getFVstr('name') . PHP_EOL);
else
  echo('Can not read id = 2' . PHP_EOL);

• 値のセットはsetFVです。最初のパラメータがフィールド名、2番目が値です。
• 値の取出しはgetFVxxxです。xxxの部分は取出す型に応じてgetFVint getFVstr getFVbin などが用意されています。

// read a record
tb.KeyNum = 0;
tb.ClearBuffer();
tb.Vlng["id"] = 2;
tb.Seek();
if (tb.Stat == 0)
  Console.WriteLine("id = 2, name = " + tb.Text["name"]);
else
  Console.WriteLine("Can not read id = 2");

• 型に応じて用意されたV64Vlng Vbin Text などの引数付きプロパティを使用して、値をセットもしくは取得します。

// read all records
tb->seekFirst();
while (tb->stat() == 0)
{
  _tprintf(_T("id = %ld name = %s\n"), tb->getFVint(_T("id")) , tb->getFVstr(_T("name")));
  tb->seekNext();
}

// read all records
tb.SeekFirst();
while (tb.Stat == 0)
{
  WScript.Echo('id = ' + tb.Vlng('id') + ', name = ' + tb.Text('name'));
  tb.SeekNext();
}

# read all records
tb.seekFirst()
while (tb.stat() == 0) do
  puts('id = ' + tb.getFVint('id').to_s() + ', name = ' + tb.getFVstr('name'))
  tb.seekNext()
end

// read all records
$tb->seekFirst();
while ($tb->stat() == 0)
{
  echo('id = ' . $tb->getFVint('id') . ', name = ' . $tb->getFVstr('name') . PHP_EOL);
  $tb->seekNext();
}

// read all records
tb.SeekFirst();
while (tb.Stat == 0)
{
  Console.WriteLine("id = " + tb.Vlng["id"] + ", name = " + tb.Text["name"]);
  tb.SeekNext();
}

// select records id >= 2 and id <= 5
const static int OR_EQUAL = true;
tb->clearBuffer();
tb->setFV(_T("id"), 2);
tb->seekGreater(OR_EQUAL);
while (tb->stat() == 0)
{
  if (tb->getFVint(_T("id")) > 5) 
    break;
  _tprintf(_T("id = %ld, name = %s\n"), tb->getFVint(_T("id")), tb->getFVstr(_T("name")));
  tb->seekNext();
}

// select records id >= 2 and id <= 5
var OR_EQUAL = true;
tb.ClearBuffer();
tb.Vlng('id') = 2;
tb.SeekGreater(OR_EQUAL);
while (tb.Stat == 0)
{
  if (tb.Vlng('id') > 5)
    break;
  WScript.Echo('id = ' + tb.Vlng('id') +  ', name = ' + tb.Text('name'));
  tb.SeekNext();
}

# select records id >= 2 and id <= 5
or_equal = true
tb.clearBuffer()
tb.setFV('id', 2)
tb.seekGreater(or_equal)
while (tb.stat() == 0) do
  break if (tb.getFVint('id') > 5)
  puts('id = ' + tb.getFVint('id').to_s() + ', name = ' + tb.getFVstr('name'))
  tb.seekNext()
end

// select records id >= 2 and id <= 5
const OR_EQUAL = true;
$tb->clearBuffer();
$tb->setFV('id', 2);
$tb->seekGreater(OR_EQUAL);
while ($tb->stat() == 0)
{
  if ($tb->getFVint('id') > 5)
    break;
  echo('id = ' . $tb->getFVint('id') . ', name = ' . $tb->getFVstr('name') . PHP_EOL);
  $tb->seekNext();
}

// select records id >= 2 and id <= 5
var OR_EQUAL = true;
tb.ClearBuffer();
tb.Vlng('id') = 2;
tb.SeekGreater(OR_EQUAL);
while (tb.Stat == 0)
{
  if (tb.Vlng["id"] > 5)
    break;
  Console.WriteLine("id = " + tb.Vlng["id"] + ", name = " + tb.Text["name"]);
  tb.SeekNext();
}

// Insert user16
tb->clearBuffer();
tb->setFV(_T("id"), 16);
tb->setFV(_T("name"), _T("user16"));
tb->setFV(_T("tel"), _T("0123-abcd-efgh"));
tb->setFV(_T("group"), 3);
tb->insert();
if (tb->stat() != 0)
  _tprintf(_T("\n Can not insert user16, stat = %d\n"), tb->stat());
else
  _tprintf(_T("\n user16 insert success.\n"));

// Insert user16
tb.ClearBuffer();
tb.Vlng('id') = 16;
tb.Text('name') = 'user16';
tb.Text('tel') = '0123-abcd-efgh';
tb.Text('group') = 3;
tb.Insert();
if (tb.Stat != 0)
  WScript.Echo('Can not insert user16, stat = ' + tb.Stat);
else
  WScript.Echo('user16 insert success.');

# Insert user16
tb.clearBuffer()
tb.setFV('id', 16)
tb.setFV('name', 'user16')
tb.setFV('tel', '0123-abcd-efgh')
tb.setFV('group', 3)
tb.insert()
if (tb.stat() != 0)
  puts('Can not insert user16, stat = ' + tb.stat().to_s())
else
  puts('user16 insert success.')
end

// Insert user16
$tb->clearBuffer();
$tb->setFV('id', 16);
$tb->setFV('name', 'user16');
$tb->setFV('tel', '0123-abcd-efgh');
$tb->setFV('group', 3);
$tb->insert();
if ($tb->stat() != 0)
  echo('Can not insert user16, stat = ' . $tb->stat() . PHP_EOL);
else
  echo('user16 insert success.');

// Insert user16
tb.ClearBuffer();
tb.Vlng["id"] = 16;
tb.Text["name"] = "user16";
tb.Text["tel"] = "0123-abcd-efgh";
tb.Vlng["group"] = 3;
tb.Insert();
if (tb.Stat != 0)
  Console.WriteLine("Can not insert id = 16, stat = " + tb.Stat);
else
  Console.WriteLine("user16 insert success.");

// Update user2 to userB
tb->clearBuffer();
tb->setFV(_T("id"), 2);
tb->seek();
if (tb->stat() == 0)
{
  tb->setFV(_T("name"), _T("userB"));
  tb->update();
  if (tb->stat() != 0)
    _tprintf(_T("\n Can not update name id = 2 stat = %d\n"), tb->stat());
  else
    _tprintf(_T("\n user2 update success.\n"));
}
else
  _tprintf(_T("\n Can not read id = 2\n"));

// Update user2 to userB
tb.ClearBuffer();
tb.Vlng('id') = 2;
tb.Seek();
if (tb.Stat == 0)
{
  tb.Text('name') = 'userB';
  tb.Update();
  if (tb.Stat != 0)
    WScript.Echo('Can not update name id = 2 stat = ' + tb.Stat);
  else
    WScript.Echo('user2 update success.');
}
else
  WScript.Echo('Can not read id = 2');

# Update user2 to userB
tb.clearBuffer()
tb.setFV('id', 2)
tb.seek()
if (tb.stat() == 0)
  tb.setFV('name', 'userB')
  tb.update()
  if (tb.stat() != 0)
    puts('Can not update name id = 2 stat = ' + tb.stat().to_s())
  else
    puts('user2 update success.')
  end
else
  puts('Can not read id = 2')
end

// Update user2 to userB
$tb->clearBuffer();
$tb->setFV('id', 2);
$tb->seek();
if ($tb->stat() == 0)
{
  $tb->setFV('name', 'userB');
  $tb->update();
  if ($tb->stat() != 0)
    echo('Can not update name id = 2 stat = ' . $tb->stat() . PHP_EOL);
  else
    echo('user2 update success.');
}
else
  echo('Can not read id = 2' . PHP_EOL);

// Update user2 to userB
tb.ClearBuffer();
tb.Vlng["id"] = 2;
tb.Seek();
if (tb.Stat == 0)
{
  tb.Text["name"] = "userB";
  tb.UpDate();
  if (tb.Stat != 0)
    Console.WriteLine("Can not update name id = 2 stat = " + tb.Stat);
  else
    Console.WriteLine("user2 update success.");
}
else
  Console.WriteLine("Can not read id = 2");

// Delete user16
tb->clearBuffer();
tb->setFV(_T("id"), 16);
tb->seek();
if (tb->stat() == 0)
{
  tb->del();
  if (tb->stat() != 0)
    _tprintf(_T("\n Can not delete id = 16, stat = %d\n"), tb->stat());
  else
    _tprintf(_T("\n user16 delete success.\n"));
}
else
  _tprintf(_T("\n Can not read id = 16\n"));

// Delete user16
tb.ClearBuffer();
tb.Vlng('id') = 16;
tb.Seek();
if (tb.Stat == 0)
{
  tb.Delete();
  if (tb.Stat != 0)
    WScript.Echo('Can not delete id = 16, stat = ' + tb.Stat);
  else
    WScript.Echo('user16 delete success.');
}
else
  WScript.Echo('Can not read id = 16');

# Delete user16
tb.clearBuffer()
tb.setFV('id', 16)
tb.seek()
if (tb.stat() == 0)
  tb.del()
  if (tb.stat() != 0)
    puts('Can not delete id = 16, stat = ' + tb.stat().to_s())
  else
    puts('user16 delete success.')
  end
else
  puts('Can not read id = 16')
end

// Delete user16
$tb->clearBuffer();
$tb->setFV('id', 16);
$tb->seek();
if ($tb->stat() == 0)
{
  $tb->del();
  if ($tb->stat() != 0)
    echo('Can not delete id = 16, stat = ' . $tb->stat() . PHP_EOL);
  else
    echo('user16 delete success.');
}
else
  echo('Can not read id = 16' . PHP_EOL);

// Delete user16
tb.ClearBuffer();
tb.Vlng["id"] = 16;
tb.Seek();
if (tb.Stat == 0)
{
  tb.Delete();
  if (tb.Stat != 0)
    Console.WriteLine("Can not delete id = 16, stat = " + tb.Stat);
  else
    Console.WriteLine("user16 delete success.");
}
else
  Console.WriteLine("Can not read id = 16");

updateUserName(table* tb, int id, const _TCHAR* name)
{
  tb->setKeyNum(0);
  tb->clearBuffer();
  tb->setFV(_T("id"), id);
  tb->seek();
  if (tb->stat() == 0)
  {
    tb->setFV(_T("name"), name);
    tb->update();
  }
  return tb->stat();
}

/* Transaction */
db->beginTrn();
short ret = updateUserName(tb, 2, _T("John"));
if (ret == 0)
  ret = updateUserName(tb, 3, _T("Akira"));
if (ret == 0)
  db->endTrn();
else
  db->abortTrn();

function updateUserName(tb, id, name)
{
  tb.KeyNum = 0;
  tb.ClearBuffer();
  tb.Vlng('id') = id;
  tb.Seek();
  if (tb.Stat == 0)
  {
    tb.Text('name') = name;
    tb.Update();
  }
  return tb.Stat;
}

// Transaction
db.BeginTrn();
var ret = updateUserName(tb, 2, 'John');
if (ret == 0)
  ret = updateUserName(tb, 2, 'Akira');
if (ret == 0)
{
  db.EndTrn();
  WScript.Echo('Commit transaction.');
}
else
{
  db.AbortTrn();
  WScript.Echo('Rollback transaction.');
}

def updateUserName(tb, id, name)
  tb.setKeyNum(0)
  tb.clearBuffer()
  tb.setFV('id', id)
  tb.seek()
  if (tb.stat() == 0)
    tb.setFV('name', name)
    tb.update()
  end
  return tb.stat()
end

db.beginTrn()
ret = updateUserName(tb, 2, 'John')
if (ret == 0)
  ret = updateUserName(tb, 2, 'Akira')
end
if (ret == 0)
  db.endTrn()
  puts('Commit transaction.')
else
  db.abortTrn()
  puts('Rollback transaction.')
end

function updateUserName($tb, $id, $name)
{
    $tb->setKeyNum(0);
    $tb->clearBuffer();
    $tb->setFV('id', $id);
    $tb->seek();
    if ($tb->stat() == 0)
    {
        $tb->setFV('name', $name);
        $tb->update();
    }
    return $tb->stat();
}

// Transaction
$db->beginTrn();
$ret = updateUserName($tb, 2, 'John');
if ($ret == 0)
    $ret = updateUserName($tb, 2, 'Akira');
if ($ret == 0)
{
    $db->endTrn();
    echo('Commit transaction.' . PHP_EOL);
}
else
{
    $db->abortTrn();
    echo('Rollback transaction.' . PHP_EOL);
}

static private eStatus updateUserName(Table tb, int id, string name)
{
  tb.KeyNum = 0;
  tb.ClearBuffer();
  tb.Vlng["id"] = id;
  tb.Seek();
  if (tb.Stat == 0)
  {
    tb.Text["name"] = name;
    tb.UpDate();
  }
  return tb.Stat;
}

// Transaction
db.BeginTrn();
eStatus ret = updateUserName(tb, 2, "John");
if (ret == 0)
  ret = updateUserName(tb, 2, "Akira");
if (ret == 0)
{
  db.EndTrn();
  Console.WriteLine("Commit transaction.");
}
else
{
  db.AbortTrn();
  Console.WriteLine("Rollback transaction.");
}

_TCHAR errorMsg[1024] = { 0x00 };
if (db->stat() != 0)
{
  db->statMsg(errorMsg);
  _tprintf(_T("database erorr No.%d %s\n"), db->stat(), errorMsg);
}

if (db.Stat != 0)
{
  WScript.Echo("database erorr No." + db.Stat + " " + db.StatMsg());
}

if db.stat() != 0
  puts('database erorr No.' + db.stat().to_s() + ' ' + db.statMsg())
end

if ($db->stat() != 0)
{
  echo('database erorr No.' . $db->stat() . ' ' . $db->statMsg() . PHP_EOL);
}

if (db.Stat != 0)
{
  Console.WriteLine("database erorr:No.{0:d} {1}.", db.Stat, db.StatMsg());
}

database* db = database::create();
db->open(uri, TYPE_SCHEMA_BDF, TD_OPEN_NORMAL);

activeTable at(db, _T("users"));
at.index(1).keyValue(0).alias(_T("name"), _T("user_name"));
// ...
database::destroy(db);

keyValue関数はtable::setFVと同様に_TCHAR* int64 int short double float などのオーバーロード関数が用意されています。

var db = new ActiveXObject('transactd.database');
db.Open(URI, TYPE_BDF, OPEN_NORMAL);

var at = new ActiveXObject('transactd.activeTable');
at.SetDatabase(db, 'users');
at.Index(1).KeyValue(0).Alias('name', 'user_name');
// ...
db.Close();

db = Transactd::Database.new()
db.open(uri, Transactd::TYPE_SCHEMA_BDF, Transactd::TD_OPEN_NORMAL)

at = Transactd::ActiveTable.new(db, 'users')
at.index(1).keyValue(0).alias('name', 'user_name')
# ...
# MUST release ActiveTable object explicitly
at.release()
db.close()

$db = new Database();
$db->open($uri, Transactd::TYPE_SCHEMA_BDF, Transactd::TD_OPEN_NORMAL);

$at = new ActiveTable($db, 'users');
$at->index(1)->keyValue(0)->alias('name', 'user_name');
// ...
$db->close();

Database db = new Database();
db.Open(uri, eSchemaType.schemaBdf, eOpenMode.normal);

ActiveTable at = new ActiveTable();
at.SetDatabase(db, "users");
at.Index(1).KeyValue(0).Alias("name", "user_name");
// ...
db.Close();

query q;
q.select(_T("id"), _T("user_name"), _T("group"), _T("tel"))
 .where(_T("group"), _T("<="), 2).reject(1);

whereの3番目のvalueパラメータはtable::setFVと同様に_TCHAR* int64 int short double floatなどのオーバーロード関数が用意されています。

var q = new ActiveXObject('transactd.query');
q.Select('id', 'user_name', 'group', 'tel')
 .Where('group', '<=', 2).Reject(1);

q = Transactd::Query.new()
q.select('id', 'user_name', 'group', 'tel')
 .where('group', '<=', 2).reject(1)

$q = new Query();
$q->select('id', 'user_name', 'group', 'tel')
  ->where('group', '<=', 2)->reject(1);

QueryBase q = new QueryBase();
q.Select("id", "user_name", "group", "tel")
 .Where("group", "<=", 2).Reject(1);

activeTable at(db, _T("users"));
at.index(1).keyValue(0).alias(_T("name"), _T("user_name"));
query q;
q.select(_T("id"), _T("user_name"), _T("group"), _T("tel"))
  .where(_T("group"), _T("<="), 2)
  .reject(1);
recordset rs;
at.read(rs, q);

var at = new ActiveXObject('transactd.activeTable');
at.SetDatabase(db, 'users');
at.Index(1).KeyValue(0).Alias('name', 'user_name');
var q = new ActiveXObject('transactd.query');
q.Select('id', 'user_name', 'group', 'tel')
  .Where('group', '<=', 2)
  .Reject(1);
var rs = at.Read(q);

at = Transactd::ActiveTable.new(db, 'users')
at.index(1).keyValue(0).alias('name', 'user_name')
q = Transactd::Query.new()
q.select('id', 'user_name', 'group', 'tel')
  .where('group', '<=', 2)
  .reject(1)
rs = at.read(q)

$at = new ActiveTable($db, 'users');
$at->index(1)->keyValue(0)->alias('name', 'user_name');
$q = new Query();
$q->select('id', 'user_name', 'group', 'tel')
  ->where('group', '<=', 2)
  ->reject(1);
$rs = $at->read($q);

ActiveTable at = new ActiveTable();
at.SetDatabase(db, "users");
at.Index(1).KeyValue(0).Alias("name", "user_name");
QueryBase q = new QueryBase();
q.Select("id", "user_name", "group", "tel")
  .Where("group", "<=", 2)
  .Reject(1);
Recordset rs = at.Read(q);

// dump recordset
void dumpRecordset(recordset& rs)
{
  std::tcout.setf(std::ios::left, std::ios::adjustfield);
  const fielddefs& fds = *rs.fieldDefs();
  for(size_t i = 0; i < rs.size(); ++i)
  {
    std::tcout << _T("[") <<  i + 1 << _T("]\n");
    row& rec = rs[i];
    for(size_t col = 0; col < rec.size(); ++col)
        std::tcout << _T("\t") << std::setw(15) 
            << fds[col].name() 
            << rec[col].c_str()
            << std::endl;
  }
}

フィールドからの値の読み出しは、型に応じてc_str i64 d getBinなどが用意されています。

// dump recordset
function dumpRecordset(rs)
{
  // get field definitions
  var fd = rs.FieldDefs;
  // show records
  for (var i = 0; i < rs.Count; i++)
  {
    WScript.Echo('[' + i + ']');
    for (var j = 0; j < rs.Record(i).Size; j++)
      WScript.Echo('\t[' + fd.FieldDef(j).Name + ']' + rs.Record(i).Field(j).Text);
  }
}

# dump recordset
def dumpRecordset(rs)
  # get field definitions
  fd = rs.fieldDefs()
  # show records
  for i in 0...rs.size()
    puts '[' + i.to_s + ']'
    for j in 0...rs[i].size()
      puts '  [' + fd[j].name + ']' + rs[i][j].str()
    end
  end
end

// dump recordset
function dumpRecordset($rs)
{
    foreach ($rs as $row_id => $record)
    {
        echo('[' . $row_id . ']' . PHP_EOL);
        foreach ($record as $field_name => $field_value)
        {
            echo("\t" . '[' . $field_name . ']' . $field_value . PHP_EOL);
        }
    }
}

// dump recordset
static void dumpRecordset(Recordset rs)
{
  // get field definitions
  FieldDefs fds = rs.FieldDefs;
  // show records
  for (UInt32 i = 0; i < rs.Size; i++)
  {
    Console.WriteLine("[" + i + "]");
    Record r = rs[i];
    for (short j = 0; j < r.Size; j++)
      Console.WriteLine("\t[{0,-15}] {1}", fds[j].Name, r[j].Text);
  }
}

rs.orderBy(_T("id"));

rs.OrderBy('id');

rs.orderBy('id')

$rs->orderBy('id');

rs.OrderBy("id");

const static bool ASC = true;
const static bool DESC = false;
sortFields orders;
orders.add(_T("group"), ASC);
orders.add(_T("id"), DESC);
rs.orderBy(orders);

var ASC = true;
var DESC = false;
var orders = new ActiveXObject('transactd.sortFields');
orders.Add('group', ASC);
orders.Add('id', DESC);
rs.OrderByEx(orders);

ASC = true
DESC = false
orders = Transactd::SortFields.new()
orders.add('group', ASC)
orders.add('id', DESC)
rs.orderBy(orders)

const ASC = true;
const DESC = false;
$orders = new SortFields();
$orders->add('group', ASC);
$orders->add('id', DESC);
$rs->orderBy($orders);

const bool ASC = true;
const bool DESC = false;
SortFields orders = new SortFields();
orders.Add("group", ASC);
orders.Add("id", DESC);
rs.OrderByEx(orders);

recordset& rs2 = *rs.clone();
// ...
rs2.release();

var rs2 = rs.Clone();

rs2 = rs.clone()

$rs2 = clone $rs;

recordsetはマジックメソッド__clone()をサポートしているので、clone文を使用できます。

Recordset rs2 = rs.Clone();

std::tcout << _T("\n groupBy group\n");
groupQuery gq;
gq.keyField(_T("group"));
count countFunc(_T("user_count"));
gq.addFunction(&countFunc);
rs2.groupBy(gq);

WScript.Echo('groupBy group');
var gq = new ActiveXObject('transactd.groupQuery');
gq.KeyField('group');
gq.AddFunction(1, null, 'user_count'); // eGroupFunc.fcount = 1
rs2.GroupBy(gq);

puts('groupBy group')
gq = Transactd::GroupQuery.new()
gq.keyField('group')
countFunc = Transactd::Count.new('user_count')
gq.addFunction(countFunc)
rs2.groupBy(gq)

echo('groupBy group');
$gq = new GroupQuery();
$gq->keyField('group');
$countFunc = new Count('user_count');
$gq->addFunction($countFunc);
$rs2->groupBy($gq);

Console.WriteLine("\ngroupBy group");
GroupQuery gq = new GroupQuery();
gq.KeyField("group");
gq.AddFunction(eGroupFunc.fcount, null, "user_count");
rs2.GroupBy(gq);

std::tcout << _T("\n groupBy with condition.\n");
rs2 = *rs.clone();
countFunc.when(_T("tel"), _T("<>") ,_T(""));
rs2.groupBy(gq);

WScript.Echo('groupBy with condition.');
var rq1 = new ActiveXObject('transactd.recordsetQuery');
rq1.When('tel', '<>', '');
gq.Reset();
gq.KeyField('group');
gq.AddFunction(1, null, 'user_count', rq1); // eGroupFunc.fcount = 1
rs2.GroupBy(gq);

puts('groupBy with condition.')
rs2 = rs.clone()
countFunc.when('tel', '<>', '')
rs2.groupBy(gq)

echo('groupBy with condition.');
$rs2 = $rs->clone();
$countFunc->when('tel', '<>', '');
$rs2->groupBy($gq);

Console.WriteLine("\ngroupBy with condition.");
RecordsetQuery rq1 = new RecordsetQuery();
rq1.When("tel", "<>", "");
gq.Reset();
gq.KeyField("group");
gq.AddFunction(eGroupFunc.fcount, null, "user_count", rq1);
rs2.GroupBy(gq);

std::tcout << _T("\n matchBy tel is not empty.\n");
recordsetQuery rq;
rq.when(_T("tel"), _T("<>"), _T(""));
rs.matchBy(rq);

WScript.Echo('matchBy tel is not empty.');
var rq = new ActiveXObject('transactd.recordsetQuery');
rq.When('tel', '<>', '');
rs.MatchBy(rq);

puts('matchBy tel is not empty.')
rq = Transactd::RecordsetQuery.new()
rq.when('tel', '<>', '')
rs.matchBy(rq)

echo('matchBy tel is not empty.');
$rq = new RecordsetQuery();
$rq->when('tel', '<>', '');
$rs->matchBy($rq);

Console.WriteLine("\nmatchBy tel is not empty.");
RecordsetQuery rq = new RecordsetQuery();
rq.When("tel", "<>", "");
rs.MatchBy(rq);

std::tcout << _T("\n append(union)  group3 users.\n");
q.reset().select(_T("id"), _T("user_name"), _T("group"), _T("tel"))
  .where(_T("group"), _T("="), _T("3")).reject(0);
recordset rs3;
at.index(1).keyValue(3).read(rs3, q);
rs += rs3;

WScript.Echo('append(union)  group3 users.');
q.Reset().Select('id', 'user_name', 'group', 'tel').Where('group', '=', 3).Reject(0);
var rs3 = at.Index(1).KeyValue(3).Read(q);
rs.UnionRecordset(rs3);

puts('append(union)  group3 users.')
q.reset().select('id', 'user_name', 'group', 'tel').where('group', '=', 3).reject(0)
rs3 = at.index(1).keyValue(3).read(q)
rs.unionRecordset(rs3)

echo('append(union)  group3 users.');
$q->reset()->select('id', 'user_name', 'group', 'tel')->where('group', '=', 3)->reject(0);
$rs3 = $at->index(1)->keyValue(3)->read($q);
$rs->unionRecordset($rs3);

Console.WriteLine("\nappend(union)  group3 users.");
q.Reset().Select("id", "user_name", "group", "tel").Where("group", "=", 3).Reject(0);
Recordset rs3 = at.Index(1).KeyValue(3).Read(q);
rs.UnionRecordset(rs3);

std::tcout << _T("\n Join group name.\n");
// open groups table
activeTable  at2(db, _T("groups"));
at2.index(0).alias(_T("name"), _T("group_name"));
// join
q.reset().select(_T("group_name"));
at2.join(rs, q, _T("group"));

WScript.Echo('Join group name.');
// open groups table
var at2 = new ActiveXObject('transactd.activeTable');
at2.SetDatabase(db, 'groups');
at2.Index(0).Alias('name', 'group_name');
// join
q.Reset().Select('group_name');
at2.Join(rs, q, 'group');

puts('Join group name.')
# open groups table
at2 = Transactd::ActiveTable.new(db, 'groups')
at2.index(0).alias('name', 'group_name')
# join
q.reset().select('group_name')
at2.join(rs, q, 'group')

echo('Join group name.');
// open groups table
$at2 = new ActiveTable($db, 'groups');
$at2->index(0)->alias('name', 'group_name');
// join
$q->reset()->select('group_name');
$at2->join($rs, $q, 'group');

Console.WriteLine("\nJoin group name.");
// open groups table
ActiveTable at2 = new ActiveTable();
at2.SetDatabase(db, "groups");
at2.Index(0).Alias("name", "group_name");
// join
q.Reset().Select("group_name");
at2.Join(rs, q, "group");

std::tcout << _T("\n Has many join.\n");
// read all groups
rs.clear();
at2.index(0).keyValue(0)
  .alias(_T("id"), _T("group_id"))
  .alias(_T("name"), _T("group_name"))
  .read(rs, q.reset());
// join groups
at.alias(_T("id"), _T("user_id"))
  .alias(_T("name"), _T("user_name"));
q.reset().select(_T("user_id"), _T("user_name"));
at.index(1).join(rs, q, _T("group_id"));

WScript.Echo('Has many join.');
// read all groups
rs = at2.Index(0).KeyValue(0)
  .Alias('id', 'group_id')
  .Alias('name', 'group_name')
  .Read(q.Reset());
// join groups
at.Alias('id', 'user_id')
  .Alias('name', 'user_name');
q.Reset().Select('user_id', 'user_name');
at.Index(1).Join(rs, q, 'group_id');

puts('Has many join.')
# read all groups
rs = at2.index(0).keyValue(0)
  .alias('id', 'group_id')
  .alias('name', 'group_name')
  .read(q.reset())
# join groups
at.alias('id', 'user_id')
  .alias('name', 'user_name')
q.reset().select('user_id', 'user_name')
at.index(1).join(rs, q, 'group_id')

echo('Has many join.');
// read all groups
$rs = $at2->index(0)->keyValue(0)
  ->alias('id', 'group_id')
  ->alias('name', 'group_name')
  ->read($q->reset());
// join groups
$at->alias('id', 'user_id')
  ->alias('name', 'user_name');
$q->reset()->select('user_id', 'user_name');
$at->index(1)->join($rs, $q, 'group_id');

Console.WriteLine("\nHas many join.");
// read all groups
rs = at2.Index(0).KeyValue(0)
  .Alias("id", "group_id")
  .Alias("name", "group_name")
  .Read(q.Reset());
// join groups
at.Alias("id", "user_id")
  .Alias("name", "user_name");
q.Reset().Select("user_id", "user_name");
at.Index(1).Join(rs, q, "group_id");

try
{
  activeTable at(db, "users");
  recordset rs;
  query q;
  at.read(rs, q);
  // ...
}
catch (bzs::rtl::exception& e)
{
  std::tcout << *(bzs::rtl::getMsg(e)) << std::endl;
}

try
{
  var at = new ActiveXObject('transactd.activeTable');
  at.SetDatabase(db, 'users');
  var rs = at.Read(q);
  // ...
}
catch(e)
{
  WScript.Echo("Error: " + e.name + " " + e.description);
}

begin
  at = Transactd::ActiveTable.new(db, 'users')
  at.read(q)
  # ...
rescue => e
  puts e.message
end

try
{
  $at = new ActiveTable(db, 'users');
  $rs = $at->read($q);
  // ...
}
catch (Exception e)
{
  echo($e->getMessage() .  PHP_EOL);
}

try
{
  ActiveTable at = new ActiveTable();
  Recordset rs = at.Read(q);
  // ...
}
catch (System.Runtime.InteropServices.COMException e)
{
  Console.WriteLine(e.Message);
}

_TCHAR errorMsg[1024] = { 0x00 };
database* db = database::create();
const _TCHAR* uri = _T("tdap://localhost/tdtutorial2?dbfile=transactd_schema");
db->create(uri);
// ...
/* close and release database object */
database::destroy(db);

var db = new ActiveXObject('transactd.database');
var URI = 'tdap://localhost/tdtutorial2?dbfile=transactd_schema';
db.Create(URI);

db = Transactd::Database.new()
URI = 'tdap://localhost/tdtutorial2?dbfile=transactd_schema'
db.create(URI)

const URI = 'tdap://localhost/tdtutorial2?dbfile=transactd_schema';
$db = new Database();
$db->create(URI);

const string uri = "tdap://localhost/tdtutorial2?dbfile=transactd_schema";
Database db = new Database();
db.Create(uri);

dbdef::insertTableの結果としてテーブル定義を表すtabledefオブジェクトが返されるので、そこにテーブル名などの情報を設定します。

dbdef* def = db->dbDef();
tabledef td;

// table name and file name
td.setTableName(_T("users"));
td.setFileName(_T("users.dat"));

td.id = 1;
def->insertTable(&td);

dbdef::insertTableの結果としてテーブル定義を表すtabledefオブジェクトが返されるので、そこにテーブル名などの情報を設定します。

var dbdef = db.DbDef;
var td = dbdef.InsertTable(1);

// table name and file name
td.TableName = 'users';
td.FileName = 'users.dat';
td.Id = 1;

まずtabledefオブジェクトを生成しテーブル名などの情報を設定します。次に、dbdef::insertTableにそのテーブル定義を渡します。

dbdef = db.dbDef()
td = Transactd::Tabledef.new()

# table name and file name
td.setTableName('users')
td.setFileName('users.dat')

td.id = 1
dbdef.insertTable(td)

まずtabledefオブジェクトを生成しテーブル名などの情報を設定します。次に、dbdef::insertTableにそのテーブル定義を渡します。

$dbdef = $db->dbDef();
$td = new Tabledef();

// table name and file name
$td->setTableName('users');
$td->setFileName('users.dat');

$td->id = 1;
$dbdef->insertTable($td);

dbdef::insertTableの結果としてテーブル定義を表すtabledefオブジェクトが返されるので、そこにテーブル名などの情報を設定します。

DbDef dbdef = db.DbDef;
TableDef td = dbdef.InsertTable(1);

// table name and file name
td.TableName = "users";
td.FileName = "users.dat";
td.Id = 1;

// [id] field
short fieldNum = 0;
fielddef* fd = def->insertField(td.id, fieldNum);
fd->setName(_T("id"));
fd->type = ft_integer;
fd->len = (ushort_td)4;

// [name] field
fd = def->insertField(td.id, ++fieldNum);
fd->setName(_T("name"));
fd->type = ft_zstring;
fd->len = 33;

// [id] field
var filedIndex = 0;
var fd = dbdef.InsertField(td.Id, filedIndex);
fd.Name = 'id';
fd.Type = ft_integer;
fd.Len = 4;

// [name] field
filedIndex = 1;
fd = dbdef.InsertField(td.Id, filedIndex);
fd.Name = 'name';
fd.Type = ft_zstring;
fd.Len = 33;

# [id] field
filedIndex = 0
fd = dbdef.insertField(td.id, filedIndex)
fd.setName('id')
fd.type = Transactd::Ft_integer
fd.len = 4

# [name] field
filedIndex = 1
fd = dbdef.insertField(td.id, filedIndex)
fd.setName('name')
fd.type = Transactd::Ft_zstring
fd.len = 33

// [id] field
$filedIndex = 0;
$fd = $dbdef->insertField($td->id, $filedIndex);
$fd->setName('id');
$fd->type = Transactd::ft_integer;
$fd->len = 4;

// [name] field
$filedIndex = 1;
$fd = $dbdef->insertField($td->id, $filedIndex);
$fd->setName('name');
$fd->type = Transactd::ft_zstring;
$fd->len = 33;

// [id] field
FieldDef fd = dbdef.InsertField(td.Id, 0);
fd.Name = "id";
fd.Type = eFieldType.ft_integer;
fd.Len = 4;

// [name] field
fd = dbdef.InsertField(td.Id, 1);
fd.Name = "name";
fd.Type = eFieldType.ft_zstring;
fd.Len = 33;

// Insert key
uchar_td keyNum = 0;
keydef* kd = def->insertKey(td.id, keyNum);
kd->segments[0].fieldNum = 0;
kd->segments[0].flags.bit8 = true; //extended type 
kd->segments[0].flags.bit1 = true; //updateable
kd->segmentCount = 1;

// set id as primary key
def->tableDefs(td.id)->primaryKeyNum = keyNum;

// update schema table
def->updateTableDef(td.id);

// add key
var keyNum = 0;
var key = dbdef.InsertKey(td.Id, keyNum);
var seg1 = key.Segments(0);
seg1.FieldNum = 0;
seg1.Flags.Bits(key_extend) = true;
seg1.Flags.Bits(key_changeable) = true;
key.SegmentCount = 1;

// set id as primary key
tableDef.PrimaryKeyNum = keyNum;

// update schema table
dbdef.UpDateTableDef(td.Id);

# add key
keyNum = 0
key = dbdef.insertKey(td.id, keyNum)
key.segment(0).fieldNum = 0
key.segment(0).flags.bit8 = 1 # key_extend
key.segment(0).flags.bit1 = 1 # key_changeable
key.segmentCount = 1

# set id as primary key
tabledef.primaryKeyNum = keyNum

# update schema table
dbdef.updateTableDef(td.id)

// add key
$keyNum = 0;
$key = $dbdef->insertKey($td->id, $keyNum);
$key->segment(0)->fieldNum = 0;
$key->segment(0)->flags->bit8 = 1; // key_extend
$key->segment(0)->flags->bit1 = 1; // key_changeable
$key->segmentCount = 1;

// set id as primary key
$td->primaryKeyNum = $keyNum;

// update schema table
$dbdef->updateTableDef($td->id);

// Insert key
byte keyNum = 0;
KeyDef kd = dbdef.InsertKey(td.Id, keyNum);
KeySegment seg = kd[0];
seg.FieldNum = 0;
seg.Flags[key_extend] = true;      // extended type
seg.Flags[key_changeable] = true;  // updateable
kd.SegmentCount = 1;

// set id as primary key
td.PrimaryKeyNum = keyNum;

// update schema table
dbdef.UpDateTableDef(td.Id);

database* db = database::create();
static const _TCHAR* uri = _T("tdap://localhost/tdtutorial2?dbfile=transactd_schema");
db->open(uri);
// drop table
db->dropTable(_T("users"));
// drop database
db->drop();
/* close and release database object */
database::destroy(db);

var db = new ActiveXObject('transactd.database');
var URI = 'tdap://localhost/tdtutorial2?dbfile=transactd_schema';
db.Open(URI);
// drop table
db.DropTable('users');
// drop database (then all tables in the database will be dropped.)
db.Drop();

db = Transactd::Database.new()
URI = 'tdap://localhost/tdtutorial2?dbfile=transactd_schema'
db.open(URI)
# drop table
db.dropTable('users')
# drop database (then all tables in the database will be dropped.)
db.drop()

$db = new Database();
const URI = 'tdap://localhost/tdtutorial2?dbfile=transactd_schema';
$db->open(URI);
// drop table
$db->dropTable('users');
// drop database (then all tables in the database will be dropped.)
$db->drop();

const string uri = "tdap://localhost/tdtutorial2?dbfile=transactd_schema";
Database db = new Database();
db.Open(uri);
// drop table
db.DropTable("users");
// drop database (then all tables in the database will be dropped.)
db.Drop();

サンプルコード（transactd_sample_cpp.zip）

サンプルコード（transactd_sample_js.zip）

サンプルコード（transactd_sample_ruby.zip）

サンプルコード（transactd_sample_php.zip）

サンプルコード（transactd_sample_csharp.zip）