serverあれこれ

H2 Database上でsardineでWebDAVサーバと連携するユーザ定義関数のまとめ

2011-06-30T22:19:00.000+09:00

WebDAVサーバ上のリソース情報の取得

WebDAVサーバ上のリソースの操作

BLOBをWebDAVサーバ上のファイルとしてアップロードする関数を作成する
CLOBをWebDAVサーバ上のファイルとしてアップロードする関数を作成する
WebDAVサーバ上のファイルをBLOBとして返す関数を作成する
WebDAVサーバ上のファイルをCLOBとして返す関数を作成する
WebDAVサーバ上のファイルをリネームする関数を作成する
WebDAVサーバ上のファイルをコピーする関数を作成する
WebDAVサーバ上のファイルを削除する関数を作成する

H2 Database上でOrion SSH2を使用するユーザー定義関数のまとめ

2011-06-22T22:07:00.001+09:00

H2 Database上でSchemaCrawlerを使用するユーザー定義関数のまとめ

2011-06-19T18:21:00.001+09:00

H2 Database上でSchemaCrawlerを使用するユーザー定義関数のまとめ

スキーマを列挙する関数を作成する

テーブルを列挙する関数を作成する

テーブルのカラムを列挙する関数を作成する

データベースの情報を取得する関数を作成する

データベースのプロパティ情報を取得する関数を作成する

SchemaCrawlerの情報を取得する関数を作成する

H2 Database上でTwitter4Jを使用するユーザー定義関数のまとめ

2011-06-11T12:49:00.002+09:00

H2 Database上でTwitter4Jを使用するユーザー定義関数のまとめ

ツィート関連

ツィートする関数を作成する

ツィート回数を取得する関数を作成する

ユーザ情報取得

接続ユーザーのタイムラインを取得する関数を作成する

ユーザー名を取得する関数を作成する

お気に入りの数を取得する関数を作成する

H2 DatabaseとSchemaCrawlerでテーブルのカラムを列挙する関数を作成する

2011-04-04T10:11:00.000+09:00

H2 DatabaseとSchemaCrawlerでテーブルのカラムを列挙する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists sc_get_columns as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import schemacrawler.schema.*;
import schemacrawler.schemacrawler.*;
import schemacrawler.utility.*;
@CODE
ResultSet sc_get_columns(String jdbcDriver, String url, 
  String user, String password, String schemaName,
  String tableName)
  throws Exception
{
  if( jdbcDriver == null ){
    throw new Exception("jdbcDriver is not specified.");
  }
  if( url == null ){
    throw new Exception("url is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null ){
    throw new Exception("password is not specified.");
  }
  if( schemaName == null ){
    throw new Exception("schemaName is not specified.");
  }
  if( tableName == null ){
    throw new Exception("tableName is not specified.");
  }
  Class.forName(jdbcDriver);
  Connection conn = null;
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("POS", Types.NUMERIC, 4, 0);
  rs.addColumn("NAME", Types.VARCHAR, 4096, 0);
  rs.addColumn("TYPENAME", Types.VARCHAR, 4096, 0);
  rs.addColumn("DECIMAL_DIGITS", Types.NUMERIC, 4, 0);
  rs.addColumn("SIZE", Types.NUMERIC, 10, 0);
  rs.addColumn("WIDTH", Types.VARCHAR, 4096, 0);
  rs.addColumn("NULLABLE", Types.BOOLEAN, 1, 0);
  try
  {
    conn = DriverManager.getConnection(url, user, password);
    SchemaCrawlerOptions options = new SchemaCrawlerOptions();
    options.setSchemaInfoLevel(SchemaInfoLevel.maximum());
    Database db = SchemaCrawlerUtility.getDatabase(conn, options);
    Schema schema = db.getSchema(schemaName);
    if( schema != null ){
      Table table = schema.getTable(tableName);
      if( table != null ){
        Column columns[] = table.getColumns();
        for(int li=0;li<columns.length;li++){
          rs.addRow(columns[li].getOrdinalPosition(), 
            columns[li].getName(),
            columns[li].getType().getTypeName(),
            columns[li].getDecimalDigits(),
            columns[li].getSize(),
            columns[li].getWidth(),
            columns[li].isNullable());
        }
      }
    }
  }
  finally
  {
    if( conn != null )conn.close();
  }
  return rs;
}
$$

実行例

select * from
sc_get_columns('org.postgresql.Driver',
  'jdbc:postgresql://localhost:5432/postgres', 
  'postgres', 'postgres', 'public', 'test1');

※以下のjarをCLASSPATH環境変数に追加
schemacrawler-8.5.1.jar, schemacrawler-postgresql-8.5.1.jar

動作環境
JDK6 Update23, H2 Database 1.2.149 (2011-01-07), SchemaCrawler 8.5.1

関連情報
SchemaCrawlerのウェブサイト
http://schemacrawler.sourceforge.net/

H2 DatabaseとJRedisでキー値が存在しない場合のみ値を設定する関数を作成する

2011-04-03T10:46:00.000+09:00

H2 DatabaseとJRedisでキー値が存在しない場合のみ値を設定する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_setnx as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Boolean jredis_setnx(String host, Integer intPort, 
  String key, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.setnx(key, value);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'key1');
select jredis_del('192.168.1.25', 6379, 'key2');
select jredis_set('192.168.1.25', 6379, 'key1', 'value1');
select jredis_setnx('192.168.1.25', 6379, 'key1', 'modified');
select jredis_setnx('192.168.1.25', 6379, 'key2', 'modified');
select jredis_get('192.168.1.25', 6379, 'key1');
select jredis_get('192.168.1.25', 6379, 'key2');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとSchemaCrawlerでテーブルを列挙する関数を作成する

2011-04-02T10:20:00.001+09:00

H2 DatabaseとSchemaCrawlerでテーブルを列挙する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists sc_get_tables as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import schemacrawler.schema.*;
import schemacrawler.schemacrawler.*;
import schemacrawler.utility.*;
@CODE
ResultSet sc_get_tables(String jdbcDriver, String url, 
  String user, String password, String schemaName)
  throws Exception
{
  if( jdbcDriver == null ){
    throw new Exception("jdbcDriver is not specified.");
  }
  if( url == null ){
    throw new Exception("url is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null ){
    throw new Exception("password is not specified.");
  }
  if( schemaName == null ){
    throw new Exception("schemaName is not specified.");
  }
  Class.forName(jdbcDriver);
  Connection conn = null;
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("NAME", Types.VARCHAR, 4096, 0);
  rs.addColumn("FULLNAME", Types.VARCHAR, 4096, 0);
  rs.addColumn("REMARKS", Types.VARCHAR, 4096, 0);
  try
  {
    conn = DriverManager.getConnection(url, user, password);
    SchemaCrawlerOptions options = new SchemaCrawlerOptions();
    Database db = SchemaCrawlerUtility.getDatabase(conn, options);
    Schema schema = db.getSchema(schemaName);
    if( schema != null ){
      Table tables[] = schema.getTables();
      for(int li=0;li<tables.length;li++){
        rs.addRow(tables[li].getName(), 
          tables[li].getFullName(),
          tables[li].getRemarks());
      }
    }
  }
  finally
  {
    if( conn != null )conn.close();
  }
  return rs;
}
$$

実行例

select * from
sc_get_tables('org.postgresql.Driver',
  'jdbc:postgresql://localhost:5432/postgres', 
  'postgres', 'postgres', 'public');

H2 DatabaseとJRedisで新しい値を設定して古い値を返す関数を作成する

2011-04-01T10:40:00.000+09:00

H2 DatabaseとJRedisで新しい値を設定して古い値を返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_getset as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
String jredis_getset(String host, Integer intPort, 
  String key, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  byte result[] = jrc.getset(key, value);
  return result==null?null:DefaultCodec.toStr(result);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'key1');
select jredis_set('192.168.1.25', 6379, 'key1', 'value1');
select jredis_getset('192.168.1.25', 6379, 'key1', 'modified');
select jredis_get('192.168.1.25', 6379, 'key1');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでSorted Setの値のスコアを取得する関数を作成する

2011-03-31T10:34:00.000+09:00

H2 DatabaseとJRedisでSorted Setの値のスコアを取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_zscore as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Double jredis_zscore(String host, Integer intPort, 
  String key, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.zscore(key, value);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'sset1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 100, 'value1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 200, 'value2');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 300, 'value3');
select jredis_zscore('192.168.1.25', 6379, 'sset1', 'value3');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでSorted Setから値を削除する関数を作成する

2011-03-30T10:24:00.001+09:00

H2 DatabaseとJRedisでSorted Setから値を削除する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_zrem as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Boolean jredis_zrem(String host, Integer intPort, 
  String key, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.zrem(key, value);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'sset1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 100, 'value1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 200, 'value2');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 300, 'value3');
select jredis_zrem('192.168.1.25', 6379, 'sset1', 'value3');
select * from jredis_zrange('192.168.1.25', 6379, 'sset1', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでSorted Setからインデックスの範囲で逆順で値を取得する関数を作成する

2011-03-29T10:18:00.000+09:00

H2 DatabaseとJRedisでSorted Setからインデックスの範囲で逆順で値を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_zrevrange as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
ResultSet jredis_zrevrange(String host, Integer intPort, 
  String key, Long from, Long to)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( from == null ){
    throw new Exception("from is not specified.");
  }
  if( to == null ){
    throw new Exception("to is not specified.");
  }
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ELEMENT", Types.VARCHAR, 4096, 0);

  JRedisClient jrc = new JRedisClient(host, port);
  for(byte elem[] : jrc.zrevrange(key, from, to)){
    rs.addRow(elem==null?null:DefaultCodec.toStr(elem));
  }
  return rs;
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'sset1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 100, 'value1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 200, 'value2');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 300, 'value3');
select * from jredis_zrevrange('192.168.1.25', 6379, 'sset1', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでスコアの範囲でSorted Setの値を取得する

2011-03-28T10:13:00.000+09:00

H2 DatabaseとJRedisでスコアの範囲でSorted Setの値を取得するには、以下のスクリプトを実行します。

create alias if not exists jredis_zrangebyscore as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
ResultSet jredis_zrangebyscore(String host, Integer intPort, 
  String key, Double from, Double to)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( from == null ){
    throw new Exception("from is not specified.");
  }
  if( to == null ){
    throw new Exception("to is not specified.");
  }
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ELEMENT", Types.VARCHAR, 4096, 0);

  JRedisClient jrc = new JRedisClient(host, port);
  for(byte elem[] : jrc.zrangebyscore(key, from, to)){
    rs.addRow(elem==null?null:DefaultCodec.toStr(elem));
  }
  return rs;
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'sset1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 100, 'value1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 200, 'value2');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 300, 'value3');
select * from jredis_zrangebyscore('192.168.1.25', 6379, 'sset1', 200, 300);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでSorted Setの要素数を取得する関数を作成する

2011-03-27T10:09:00.001+09:00

H2 DatabaseとJRedisでSorted Setの要素数を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_zcard as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Long jredis_zcard(String host, Integer intPort, 
  String key)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.zcard(key);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'sset1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 100, 'value1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 200, 'value2');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 300, 'value3');
select jredis_zcard('192.168.1.25', 6379, 'sset1');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでSorted Setの値のスコアをインクリメントする関数を作成する

2011-03-26T10:05:00.000+09:00

H2 DatabaseとJRedisでSorted Setの値のスコアをインクリメントする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_zincrby as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Double jredis_zincrby(String host, Integer intPort, 
  String key, Double score, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( score == null ){
    throw new Exception("score is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.zincrby(key, score, value);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'sset1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 100, 'value1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 200, 'value2');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 300, 'value3');
select jredis_zincrby('192.168.1.25', 6379, 'sset1', 1000, 'value2');
select * from jredis_zrange('192.168.1.25', 6379, 'sset1', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでSorted Setからインデックスの範囲で値を取得する関数を作成する

2011-03-25T10:55:00.001+09:00

H2 DatabaseとJRedisでSorted Setからインデックスの範囲で値を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_zrange as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
ResultSet jredis_zrange(String host, Integer intPort, 
  String key, Long from, Long to)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( from == null ){
    throw new Exception("from is not specified.");
  }
  if( to == null ){
    throw new Exception("to is not specified.");
  }
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ELEMENT", Types.VARCHAR, 4096, 0);

  JRedisClient jrc = new JRedisClient(host, port);
  for(byte elem[] : jrc.zrange(key, from, to)){
    rs.addRow(elem==null?null:DefaultCodec.toStr(elem));
  }
  return rs;
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'sset1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 100, 'value1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 200, 'value2');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 300, 'value3');
select * from jredis_zrange('192.168.1.25', 6379, 'sset1', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでSorted Setに値を追加する関数を作成する

2011-03-24T10:48:00.000+09:00

H2 DatabaseとJRedisでSorted Setに値を追加する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_zadd as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Boolean jredis_zadd(String host, Integer intPort, 
  String key, Double score, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( score == null ){
    throw new Exception("score is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.zadd(key, score, value);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'sset1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 100, 'value1');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 200, 'value2');
select jredis_zadd('192.168.1.25', 6379, 'sset1', 300, 'value3');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでセットから値を削除する関数を作成する

2011-03-23T10:41:00.000+09:00

H2 DatabaseとJRedisでセットから値を削除する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_srem as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Boolean jredis_srem(String host, Integer intPort, 
  String key, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.srem(key, value);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value3');
select jredis_srem('192.168.1.25', 6379, 'set1', 'value1');
select * from jredis_smembers('192.168.1.25', 6379, 'set1');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとSchemaCrawlerでスキーマを列挙する関数を作成する

2011-03-22T15:09:00.001+09:00

H2 DatabaseとSchemaCrawlerでスキーマを列挙する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists sc_get_schemas as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import schemacrawler.schema.*;
import schemacrawler.schemacrawler.*;
import schemacrawler.utility.*;
@CODE
ResultSet sc_get_schemas(String jdbcDriver, String url, 
  String user, String password)
  throws Exception
{
  if( jdbcDriver == null ){
    throw new Exception("jdbcDriver is not specified.");
  }
  if( url == null ){
    throw new Exception("url is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null ){
    throw new Exception("password is not specified.");
  }
  Class.forName(jdbcDriver);
  Connection conn = null;
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("CATALOG", Types.VARCHAR, 4096, 0);
  rs.addColumn("SCHEMA", Types.VARCHAR, 4096, 0);
  try
  {
    conn = DriverManager.getConnection(url, user, password);
    SchemaCrawlerOptions options = new SchemaCrawlerOptions();
    Database db = SchemaCrawlerUtility.getDatabase(conn, options);
    Schema schemas[] = db.getSchemas();
    for(int li=0;li<schemas.length;li++){
      rs.addRow(schemas[li].getCatalogName(), 
        schemas[li].getSchemaName());
    }
  }
  finally
  {
    if( conn != null )conn.close();
  }
  return rs;
}
$$

実行例

select * from
sc_get_schemas('org.postgresql.Driver',
  'jdbc:postgresql://localhost:5432/postgres', 
  'postgres', 'postgres');

H2 DatabaseとJRedisでサーバの情報を返す関数を作成する

2011-03-22T10:36:00.000+09:00

H2 DatabaseとJRedisでサーバの情報を返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_info as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
ResultSet jredis_info(String host, Integer intPort)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("KEY", Types.VARCHAR, 4096, 0);
  rs.addColumn("VALUE", Types.VARCHAR, 4096, 0);

  JRedisClient jrc = new JRedisClient(host, port);
  for(Map.Entry elem : jrc.info().entrySet()){
    rs.addRow(elem.getKey(), elem.getValue());
  }

  return rs;
}
$$

実行例

select * from jredis_info('192.168.1.25', 6379);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisで複数のセットから差集合を作成する関数を作成する

2011-03-21T10:21:00.000+09:00

H2 DatabaseとJRedisで複数のセットから差集合を作成する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_sdiffstore as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Integer jredis_sdiffstore(String host, Integer intPort, 
  String dest, String set1, String set2)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( dest == null ){
    throw new Exception("dest is not specified.");
  }
  if( set1 == null ){
    throw new Exception("set1 is not specified.");
  }
  if( set2 == null ){
    throw new Exception("set2 is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  jrc.sdiffstore(dest, set1, set2);
  return new Integer(0);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_del('192.168.1.25', 6379, 'set2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value3');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value5');
select jredis_sdiffstore('192.168.1.25', 6379, 'rs', 'set1', 'set2');
select * from jredis_smembers('192.168.1.25', 6379, 'rs');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisで複数のセットから和集合を作成する関数を作成する

2011-03-20T10:15:00.000+09:00

H2 DatabaseとJRedisで複数のセットから和集合を作成する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_sunionstore as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Integer jredis_sunionstore(String host, Integer intPort, 
  String dest, String set1, String set2)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( dest == null ){
    throw new Exception("dest is not specified.");
  }
  if( set1 == null ){
    throw new Exception("set1 is not specified.");
  }
  if( set2 == null ){
    throw new Exception("set2 is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  jrc.sunionstore(dest, set1, set2);
  return new Integer(0);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_del('192.168.1.25', 6379, 'set2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value3');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value5');
select jredis_sunionstore('192.168.1.25', 6379, 'rs', 'set1', 'set2');
select * from jredis_smembers('192.168.1.25', 6379, 'rs');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisで複数のセットから積集合を作成する関数を作成する

2011-03-19T10:09:00.001+09:00

H2 DatabaseとJRedisで複数のセットから積集合を作成する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_sinterstore as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Integer jredis_sinterstore(String host, Integer intPort, 
  String dest, String set1, String set2)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( dest == null ){
    throw new Exception("dest is not specified.");
  }
  if( set1 == null ){
    throw new Exception("set1 is not specified.");
  }
  if( set2 == null ){
    throw new Exception("set2 is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  jrc.sinterstore(dest, set1, set2);
  return new Integer(0);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_del('192.168.1.25', 6379, 'set2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value3');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value5');
select jredis_sinterstore('192.168.1.25', 6379, 'rs', 'set1', 'set2');
select * from jredis_smembers('192.168.1.25', 6379, 'rs');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisで複数のセットから差集合を返す関数を作成する

2011-03-18T10:02:00.001+09:00

H2 DatabaseとJRedisで複数のセットから差集合を返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_sdiff as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
ResultSet jredis_sdiff(String host, Integer intPort, 
  String key1, String key2)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key1 == null ){
    throw new Exception("key1 is not specified.");
  }
  if( key2 == null ){
    throw new Exception("key2 is not specified.");
  }
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ELEMENT", Types.VARCHAR, 4096, 0);

  JRedisClient jrc = new JRedisClient(host, port);
  for(byte elem[] : jrc.sdiff(key1, key2)){
    rs.addRow(elem==null?null:DefaultCodec.toStr(elem));
  }
  return rs;
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_del('192.168.1.25', 6379, 'set2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value3');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value5');
select * from jredis_sdiff('192.168.1.25', 6379, 'set1', 'set2');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisで複数のセットから和集合を返す関数を作成する

2011-03-17T10:57:00.001+09:00

H2 DatabaseとJRedisで複数のセットから和集合を返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_sunion as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
ResultSet jredis_sunion(String host, Integer intPort, 
  String key1, String key2)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key1 == null ){
    throw new Exception("key1 is not specified.");
  }
  if( key2 == null ){
    throw new Exception("key2 is not specified.");
  }
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ELEMENT", Types.VARCHAR, 4096, 0);

  JRedisClient jrc = new JRedisClient(host, port);
  for(byte elem[] : jrc.sunion(key1, key2)){
    rs.addRow(elem==null?null:DefaultCodec.toStr(elem));
  }
  return rs;
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_del('192.168.1.25', 6379, 'set2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value3');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value5');
select * from jredis_sunion('192.168.1.25', 6379, 'set1', 'set2');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisで複数のセットから積集合を返す関数を作成する

2011-03-16T10:52:00.001+09:00

H2 DatabaseとJRedisで複数のセットから積集合を返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_sinter as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
ResultSet jredis_sinter(String host, Integer intPort, 
  String key1, String key2)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key1 == null ){
    throw new Exception("key1 is not specified.");
  }
  if( key2 == null ){
    throw new Exception("key2 is not specified.");
  }
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ELEMENT", Types.VARCHAR, 4096, 0);

  JRedisClient jrc = new JRedisClient(host, port);
  for(byte elem[] : jrc.sinter(key1, key2)){
    rs.addRow(elem==null?null:DefaultCodec.toStr(elem));
  }
  return rs;
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_del('192.168.1.25', 6379, 'set2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value3');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set2', 'value5');
select * from jredis_sinter('192.168.1.25', 6379, 'set1', 'set2');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでセットからランダムに値を返す関数を作成する

2011-03-15T10:45:00.001+09:00

H2 DatabaseとJRedisでセットからランダムに値を返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_srandmember as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
String jredis_srandmember(String host, Integer intPort, 
  String key)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  byte result[] = jrc.srandmember(key);
  return result==null?null:DefaultCodec.toStr(result);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value3');
select jredis_srandmember('192.168.1.25', 6379, 'set1');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでセットの値を別のセットに移動させる関数を作成する

2011-03-14T10:37:00.000+09:00

H2 DatabaseとJRedisでセットの値を別のセットに移動させる関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_smove as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Boolean jredis_smove(String host, Integer intPort, 
  String srcKey, String destKey, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( srcKey == null ){
    throw new Exception("srcKey is not specified.");
  }
  if( destKey == null ){
    throw new Exception("destKey is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.smove(srcKey, destKey, value);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_del('192.168.1.25', 6379, 'set2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value3');
select jredis_smove('192.168.1.25', 6379, 'set1', 'set2', 'value2');
select * from jredis_smembers('192.168.1.25', 6379, 'set1');
select * from jredis_smembers('192.168.1.25', 6379, 'set2');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでセットに含まれる値を返す関数を作成する

2011-03-13T10:10:00.000+09:00

H2 DatabaseとJRedisでセットに含まれる値を返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_smembers as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
ResultSet jredis_smembers(String host, Integer intPort, 
  String key)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ELEMENT", Types.VARCHAR, 4096, 0);

  JRedisClient jrc = new JRedisClient(host, port);
  for(byte elem[] : jrc.smembers(key)){
    rs.addRow(elem==null?null:DefaultCodec.toStr(elem));
  }
  return rs;
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value3');
select * from jredis_smembers('192.168.1.25', 6379, 'set1');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseでSchemaCrawlerの情報を取得する関数を作成する

2011-03-12T15:01:00.001+09:00

H2 DatabaseでSchemaCrawlerの情報を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists sc_get_scinfo as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import schemacrawler.schema.*;
import schemacrawler.schemacrawler.*;
import schemacrawler.utility.*;
@CODE
ResultSet sc_get_scinfo(String jdbcDriver, String url, 
  String user, String password)
  throws Exception
{
  if( jdbcDriver == null ){
    throw new Exception("jdbcDriver is not specified.");
  }
  if( url == null ){
    throw new Exception("url is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null ){
    throw new Exception("password is not specified.");
  }
  Class.forName(jdbcDriver);
  Connection conn = null;
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("NAME", Types.VARCHAR, 4096, 0);
  rs.addColumn("VALUE", Types.VARCHAR, 4096, 0);
  try
  {
    conn = DriverManager.getConnection(url, user, password);
    SchemaCrawlerOptions options = new SchemaCrawlerOptions();
    Database db = SchemaCrawlerUtility.getDatabase(conn, options);
    SchemaCrawlerInfo sci = db.getSchemaCrawlerInfo();
    rs.addRow("About", sci.getSchemaCrawlerAbout());
    rs.addRow("ProductName", sci.getSchemaCrawlerProductName());
    rs.addRow("Version", sci.getSchemaCrawlerVersion());
  }
  finally
  {
    if( conn != null )conn.close();
  }
  return rs;
}
$$

実行例

select * from
sc_get_scinfo('org.postgresql.Driver',
  'jdbc:postgresql://localhost:5432/postgres', 
  'postgres', 'postgres');

H2 DatabaseとJRedisでセットに値が含まれるか確認する関数を作成する

2011-03-12T10:59:00.001+09:00

H2 DatabaseとJRedisでセットに値が含まれるか確認する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_sismember as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Boolean jredis_sismember(String host, Integer intPort, 
  String key, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.sismember(key, value);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value2');
select jredis_sismember('192.168.1.25', 6379, 'set1', 'value1') as result1,
  jredis_sismember('192.168.1.25', 6379, 'set1', 'value0') as result2;

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでセットに値を追加する関数を作成する

2011-03-11T10:52:00.001+09:00

H2 DatabaseとJRedisでセットに値を追加する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_sadd as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Boolean jredis_sadd(String host, Integer intPort, 
  String key, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.sadd(key, value);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'set1');
select jredis_sadd('192.168.1.25', 6379, 'set1', 'value1');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでバックグラウンドでDBを保存する関数を作成する

2011-03-10T10:45:00.000+09:00

H2 DatabaseとJRedisでバックグラウンドでDBを保存する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_bgsave as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Long jredis_bgsave(String host, Integer intPort)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }

  JRedisClient jrc = new JRedisClient(host, port);
  jrc.bgsave();
  return new Long(0);
}
$$

実行例

select jredis_bgsave('192.168.1.25', 6379);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでソースリストから最後の要素を取得・削除して値を別のリストの最初に追加する関数を作成する

2011-03-09T10:39:00.001+09:00

H2 DatabaseとJRedisでソースリストから最後の要素を取得・削除して値を別のリストの最初に追加する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_rpoplpush as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
String jredis_rpoplpush(String host, Integer intPort, 
  String srcKey, String destKey)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( srcKey == null ){
    throw new Exception("srcKey is not specified.");
  }
  if( destKey == null ){
    throw new Exception("destKey is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  byte result[] = jrc.rpoplpush(srcKey, destKey);
  return result==null?null:DefaultCodec.toStr(result);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'list1');
select jredis_del('192.168.1.25', 6379, 'list2');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value2');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value3');
select jredis_rpoplpush('192.168.1.25', 6379, 'list1', 'list2');
select * from jredis_lrange('192.168.1.25', 6379, 'list1', 0, -1);
select * from jredis_lrange('192.168.1.25', 6379, 'list2', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでリストから指定のインデックスの要素を取得する関数を作成する

2011-03-08T10:25:00.000+09:00

H2 DatabaseとJRedisでリストから指定のインデックスの要素を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_lindex as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
String jredis_lindex(String host, Integer intPort, 
  String key, Long index)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( index == null ){
    throw new Exception("index is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  byte result[] = jrc.lindex(key, index);
  return result==null?null:DefaultCodec.toStr(result);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'list1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value2');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value3');
select jredis_lindex('192.168.1.25', 6379, 'list1', 1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでリストの最後の要素を取得して削除する関数を作成する

2011-03-07T10:20:00.001+09:00

H2 DatabaseとJRedisでリストの最後の要素を取得して削除する関数を作成するには、以下のコードを実行します。

create alias if not exists jredis_rpop as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
String jredis_rpop(String host, Integer intPort, 
  String key)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  byte result[] = jrc.rpop(key);
  return result==null?null:DefaultCodec.toStr(result);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'list1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value2');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value3');
select jredis_rpop('192.168.1.25', 6379, 'list1');
select * from jredis_lrange('192.168.1.25', 6379, 'list1', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでリストの最初の要素を取得して削除する関数を作成する

2011-03-06T12:15:00.000+09:00

H2 DatabaseとJRedisでリストの最初の要素を取得して削除する関数を作成するには、以下のコードを実行します。

create alias if not exists jredis_lpop as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
String jredis_lpop(String host, Integer intPort, 
  String key)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  byte result[] = jrc.lpop(key);
  return result==null?null:DefaultCodec.toStr(result);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'list1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value2');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value3');
select jredis_lpop('192.168.1.25', 6379, 'list1');
select * from jredis_lrange('192.168.1.25', 6379, 'list1', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでリストの指定した要素を削除する関数を作成する

2011-03-05T10:08:00.000+09:00

H2 DatabaseとJRedisでリストの指定した要素を削除する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_lrem as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Long jredis_lrem(String host, Integer intPort, 
  String key, String value, Integer count)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }
  if( count == null ){
    throw new Exception("count is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.lrem(key, value, count);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'list1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value2');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value3');
select jredis_lrem('192.168.1.25', 6379, 'list1', 'value1', 0);
select * from jredis_lrange('192.168.1.25', 6379, 'list1', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでリストの指定した範囲の要素のみを残す関数を作成する

2011-03-04T10:47:00.000+09:00

H2 DatabaseとJRedisでリストの指定した範囲の要素のみを残す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_ltrim as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Integer jredis_ltrim(String host, Integer intPort, 
  String key, Long keepFrom, Long keepTo)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( keepFrom == null ){
    throw new Exception("keepFrom is not specified.");
  }
  if( keepTo == null ){
    throw new Exception("keepTo is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  jrc.ltrim(key, keepFrom, keepTo);
  return new Integer(0);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'list1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value2');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value3');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value4');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value5');
select jredis_ltrim('192.168.1.25', 6379, 'list1', 1, 3);
select * from jredis_lrange('192.168.1.25', 6379, 'list1', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでリストのインデックスを指定して値を設定する関数を作成する

2011-03-03T10:41:00.000+09:00

H2 DatabaseとJRedisでリストのインデックスを指定して値を設定する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_lset as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Integer jredis_lset(String host, Integer intPort, 
  String key, Long index, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( index == null ){
    throw new Exception("index is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  jrc.lset(key, index, value);
  return new Integer(0);
}
$$

実行例

select jredis_del('192.168.1.25', 6379, 'list1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value1');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value2');
select jredis_rpush('192.168.1.25', 6379, 'list1', 'value3');
select jredis_lset('192.168.1.25', 6379, 'list1', 1, 'modified');
select * from jredis_lrange('192.168.1.25', 6379, 'list1', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとSchemaCrawlerでデータベースのプロパティ情報を取得する関数を作成する

2011-03-02T15:47:00.000+09:00

H2 DatabaseとSchemaCrawlerでデータベースのプロパティ情報を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists sc_get_dbprops as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import schemacrawler.schema.*;
import schemacrawler.schemacrawler.*;
import schemacrawler.utility.*;
@CODE
ResultSet sc_get_dbprops(String jdbcDriver, String url, 
  String user, String password)
  throws Exception
{
  if( jdbcDriver == null ){
    throw new Exception("jdbcDriver is not specified.");
  }
  if( url == null ){
    throw new Exception("url is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null ){
    throw new Exception("password is not specified.");
  }
  Class.forName(jdbcDriver);
  Connection conn = null;
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("NAME", Types.VARCHAR, 4096, 0);
  rs.addColumn("VALUE", Types.VARCHAR, 4096, 0);
  rs.addColumn("DESCRIPTION", Types.VARCHAR, 4096, 0);
  try
  {
    conn = DriverManager.getConnection(url, user, password);
    SchemaCrawlerOptions options = new SchemaCrawlerOptions();
    options.setSchemaInfoLevel(SchemaInfoLevel.maximum());
    Database db = SchemaCrawlerUtility.getDatabase(conn, options);
    DatabaseInfo dbi = db.getDatabaseInfo();
    DatabaseProperty props[] = dbi.getProperties();
    for(int pl=0;pl<props.length;pl++){
      rs.addRow(props[pl].getName(), 
        props[pl].getValue(), props[pl].getDescription());
    }
  }
  finally
  {
    if( conn != null )conn.close();
  }
  return rs;
}
$$

実行例

select * from
sc_get_dbprops('org.postgresql.Driver',
  'jdbc:postgresql://localhost:5432/postgres', 
  'postgres', 'postgres');

H2 DatabaseとJRedisでリストの要素数を返す関数を作成する

2011-03-02T10:13:00.000+09:00

H2 DatabaseとJRedisでリストの要素数を返す関数を作成するには、以下のコードを実行します。

create alias if not exists jredis_llen as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
long jredis_llen(String host, Integer intPort, 
  String key)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.llen(key);
}
$$

実行例

select jredis_lpush('192.168.1.25', 6379, 'list1', 'value1');
select jredis_llen('192.168.1.25', 6379, 'list1');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでリストの最初に値を追加する関数を作成する

2011-03-01T10:07:00.000+09:00

H2 DatabaseとJRedisでリストの最初に値を追加する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_lpush as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Integer jredis_lpush(String host, Integer intPort, 
  String key, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  jrc.lpush(key, value);
  return new Integer(0);
}
$$

実行例

select jredis_lpush('192.168.1.25', 6379, 'list1', 'value1');
select * from jredis_lrange('192.168.1.25', 6379, 'list1', 0, -1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでリストの指定した範囲の値を列挙する関数を作成する

2011-02-28T10:01:00.001+09:00

H2 DatabaseとJRedisでリストの指定した範囲の値を列挙する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_lrange as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
ResultSet jredis_lrange(String host, Integer intPort, 
  String key, Long from, Long to)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( from == null ){
    throw new Exception("from is not specified.");
  }
  if( to == null ){
    throw new Exception("to is not specified.");
  }
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ELEMENT", Types.VARCHAR, 4096, 0);

  JRedisClient jrc = new JRedisClient(host, port);
  for(byte elem[] : jrc.lrange(key, from, to)){
    rs.addRow(elem==null?null:DefaultCodec.toStr(elem));
  }
  return rs;
}
$$

実行例

select * from jredis_lrange('192.168.1.25', 6379, 'list1', 0, -1)

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでリストの最後に値を追加する関数を作成する

2011-02-27T10:59:00.000+09:00

H2 DatabaseとJRedisでリストの最後に値を追加する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_rpush as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Integer jredis_rpush(String host, Integer intPort, 
  String key, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  jrc.rpush(key, value);
  return new Integer(0);
}
$$

実行例

select jredis_rpush('192.168.1.25', 6379, 'list1', 'value1')

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでキーを削除する関数を作成する

2011-02-26T10:46:00.000+09:00

H2 DatabaseとJRedisでキーを削除する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_del as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
boolean jredis_del(String host, Integer intPort, 
  String key)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.del(key);
}
$$

実行例

select jredis_set('192.168.1.25', 6379, 'key1', 'value1');
select jredis_del('192.168.1.25', 6379, 'key1');
select jredis_exists('192.168.1.25', 6379, 'key1');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisで最後にディスクに保存した日付を取得する関数を作成する

2011-02-25T10:41:00.001+09:00

H2 DatabaseとJRedisで最後にディスクに保存した日付を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_lastsave as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
java.sql.Date jredis_lastsave(String host, Integer intPort)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return new java.sql.Date(jrc.lastsave());
}
$$

実行例

select jredis_lastsave('192.168.1.25', 6379);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでkeyの数を取得する関数を作成する

2011-02-24T10:36:00.000+09:00

H2 DatabaseとJRedisでkeyの数を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_dbsize as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
long jredis_dbsize(String host, Integer intPort)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.dbsize();
}
$$

実行例

select jredis_dbsize('192.168.1.25', 6379);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとJRedisでkeyの値をデクリメントする関数を作成する

2011-02-23T10:27:00.001+09:00

H2 DatabaseとJRedisでkeyの値をデクリメントする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_decrby as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
long jredis_decrby(String host, Integer intPort, 
  String key, Integer delta)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( delta == null ){
    throw new Exception("delta is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.decrby(key, delta.intValue());
}
$$

実行例

select jredis_set('192.168.1.25', 6379, 'key1', '10');
select jredis_decrby('192.168.1.25', 6379, 'key1', 2);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとTwitter4Jを使用してフォローしているユーザ名を取得する関数を作成する

2011-02-22T10:04:00.001+09:00

H2 DatabaseとTwitter4Jを使用してフォローしているユーザ名を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists twitter_get_friends_ids as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import twitter4j.*;
import twitter4j.http.*;
import twitter4j.conf.*;
@CODE
ResultSet twitter_get_friends_ids(String consumerKey, 
  String consumerSecret, String accessToken,
  String accessTokenSecret)
  throws Exception
{
  if( consumerKey == null ){
    throw new Exception("consumerKey is not specified.");
  }
  if( consumerSecret == null ){
    throw new Exception("consumerSecret is not specified.");
  }
  if( accessToken == null ){
    throw new Exception("accessToken is not specified.");
  }
  if( accessTokenSecret == null ){
    throw new Exception("accessTokenSecret is not specified.");
  }

  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ID", Types.NUMERIC, 20, 0);
  rs.addColumn("NAME", Types.VARCHAR, 100, 0);

  Properties prop = new Properties();
  prop.put("oauth.consumerKey", consumerKey);
  prop.put("oauth.consumerSecret", consumerSecret);
  prop.put("oauth.accessToken", accessToken);
  prop.put("oauth.accessTokenSecret", accessTokenSecret);
  PropertyConfiguration pc = 
     new PropertyConfiguration(prop);

  OAuthAuthorization oauth = new OAuthAuthorization(pc);
  TwitterFactory tf = new TwitterFactory();
  Twitter twitter = tf.getInstance(oauth);
  IDs ids = twitter.getFriendsIDs();
  int idns[] = ids.getIDs();
  for(int idx=0;idx<idns.length;idx++){
    User user = twitter.showUser(idns[idx]);
    rs.addRow(user.getId(), user.getScreenName());
  }
  return rs;
}
$$

実行例

select * from twitter_get_friends_ids('xxxx',
'xxxx',
'xxxx',
'xxxx');

H2 DatabaseとJRedisでkeyの値をインクリメントする関数を作成する

2011-02-21T10:22:00.001+09:00

H2 DatabaseとJRedisでkeyの値をインクリメントする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_incrby as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
long jredis_incrby(String host, Integer intPort, 
  String key, Integer delta)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( delta == null ){
    throw new Exception("delta is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.incrby(key, delta.intValue());
}
$$

実行例

select jredis_set('192.168.1.25', 6379, 'key1', '10');
select jredis_incrby('192.168.1.25', 6379, 'key1', 1);

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとSchemaCrawlerでデータベースの情報を取得する関数を作成する

2011-02-20T17:36:00.001+09:00

H2 DatabaseとSchemaCrawlerでデータベースの情報を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists sc_get_dbinfo as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import schemacrawler.schema.*;
import schemacrawler.schemacrawler.*;
import schemacrawler.utility.*;
@CODE
ResultSet sc_get_dbinfo(String jdbcDriver, String url, 
  String user, String password)
  throws Exception
{
  if( jdbcDriver == null ){
    throw new Exception("jdbcDriver is not specified.");
  }
  if( url == null ){
    throw new Exception("url is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null ){
    throw new Exception("password is not specified.");
  }
  Class.forName(jdbcDriver);
  Connection conn = null;
  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("NAME", Types.VARCHAR, 4096, 0);
  rs.addColumn("VALUE", Types.VARCHAR, 4096, 0);
  try
  {
    conn = DriverManager.getConnection(url, user, password);
    SchemaCrawlerOptions options = new SchemaCrawlerOptions();
    Database db = SchemaCrawlerUtility.getDatabase(conn, options);
    DatabaseInfo dbi = db.getDatabaseInfo();
    rs.addRow("ProductName", dbi.getProductName());
    rs.addRow("ProductVersion", dbi.getProductVersion());
    rs.addRow("UserName", dbi.getUserName());
  }
  finally
  {
    if( conn != null )conn.close();
  }
  return rs;
}
$$

実行例

select * from
sc_get_dbinfo('org.postgresql.Driver',
  'jdbc:postgresql://localhost:5432/postgres', 
  'postgres', 'postgres');

H2 DatabaseとTwitter4Jを使用してフォロワーのユーザ名を取得する関数を作成する

2011-02-20T10:57:00.001+09:00

H2 DatabaseとTwitter4Jを使用してフォロワーのユーザ名を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists twitter_get_follower_ids as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import twitter4j.*;
import twitter4j.http.*;
import twitter4j.conf.*;
@CODE
ResultSet twitter_get_follower_ids(String consumerKey, 
  String consumerSecret, String accessToken,
  String accessTokenSecret)
  throws Exception
{
  if( consumerKey == null ){
    throw new Exception("consumerKey is not specified.");
  }
  if( consumerSecret == null ){
    throw new Exception("consumerSecret is not specified.");
  }
  if( accessToken == null ){
    throw new Exception("accessToken is not specified.");
  }
  if( accessTokenSecret == null ){
    throw new Exception("accessTokenSecret is not specified.");
  }

  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ID", Types.NUMERIC, 20, 0);
  rs.addColumn("NAME", Types.VARCHAR, 100, 0);

  Properties prop = new Properties();
  prop.put("oauth.consumerKey", consumerKey);
  prop.put("oauth.consumerSecret", consumerSecret);
  prop.put("oauth.accessToken", accessToken);
  prop.put("oauth.accessTokenSecret", accessTokenSecret);
  PropertyConfiguration pc = 
     new PropertyConfiguration(prop);

  OAuthAuthorization oauth = new OAuthAuthorization(pc);
  TwitterFactory tf = new TwitterFactory();
  Twitter twitter = tf.getInstance(oauth);
  IDs ids = twitter.getFollowersIDs();
  int idns[] = ids.getIDs();
  for(int idx=0;idx<idns.length;idx++){
    User user = twitter.showUser(idns[idx]);
    rs.addRow(user.getId(), user.getScreenName());
  }
  return rs;
}
$$

実行例

select * from twitter_get_follower_ids('xxxx',
'xxxx',
'xxxx',
'xxxx');

※以下のjarをCLASSPATH環境変数に追加
twitter4j-core-2.1.12-SNAPSHOT.jar

動作環境
JDK6 Update23, H2 Database 1.2.149 (2011-01-07), twitter4j-2.1.12-SNAPSHOT

関連情報
H2 Database上でTwitter4Jを使用するユーザー定義関数のまとめ

H2 DatabaseとJRedisでkeyをリネームする関数を作成する

2011-02-19T10:14:00.002+09:00

H2 DatabaseとJRedisでkeyをリネームする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_rename as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Integer jredis_rename(String host, Integer intPort, 
  String oldkey, String newkey)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( oldkey == null ){
    throw new Exception("old key is not specified.");
  }
  if( newkey == null ){
    throw new Exception("new key is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  jrc.rename(oldkey, newkey);
  return new Integer(0);
}
$$

実行例

select jredis_rename('192.168.1.25', 6379, 'key1', 'newkey1')

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとTwitter4Jを使用して接続ユーザーのタイムラインを取得する関数を作成する

2011-02-18T10:49:00.001+09:00

H2 DatabaseとTwitter4Jを使用して接続ユーザーのタイムラインを取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists twitter_get_user_timeline as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import twitter4j.*;
import twitter4j.http.*;
import twitter4j.conf.*;
@CODE
ResultSet twitter_get_user_timeline(String consumerKey, 
  String consumerSecret, String accessToken,
  String accessTokenSecret, Integer page)
  throws Exception
{
  if( consumerKey == null ){
    throw new Exception("consumerKey is not specified.");
  }
  if( consumerSecret == null ){
    throw new Exception("consumerSecret is not specified.");
  }
  if( accessToken == null ){
    throw new Exception("accessToken is not specified.");
  }
  if( accessTokenSecret == null ){
    throw new Exception("accessTokenSecret is not specified.");
  }
  if( page == null ){
    return null;
  }

  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("ID", Types.NUMERIC, 20, 0);
  rs.addColumn("CREATEDAT", Types.TIMESTAMP, 0, 0);
  rs.addColumn("NAME", Types.VARCHAR, 100, 0);
  rs.addColumn("TWEET", Types.VARCHAR, 140, 0);

  Properties prop = new Properties();
  prop.put("oauth.consumerKey", consumerKey);
  prop.put("oauth.consumerSecret", consumerSecret);
  prop.put("oauth.accessToken", accessToken);
  prop.put("oauth.accessTokenSecret", accessTokenSecret);
  PropertyConfiguration pc = 
     new PropertyConfiguration(prop);

  OAuthAuthorization oauth = new OAuthAuthorization(pc);
  TwitterFactory tf = new TwitterFactory();
  Twitter twitter = tf.getInstance(oauth);
  ResponseList<Status> rl = twitter.getUserTimeline(new Paging(page));
  for(Status status : rl){
    rs.addRow(status.getId(), 
      new Timestamp(status.getCreatedAt().getTime()),
      status.getUser().getScreenName(),
      status.getText());
  }
  return rs;
}
$$

実行例

select * from twitter_get_user_timeline('xxxx',
'xxxx',
'xxxx',
'xxxx', 1);

H2 DatabaseとOrion SSH2を使用してサーバ上でコマンドを実行する関数を作成する

2011-02-17T10:17:00.002+09:00

H2 DatabaseとOrion SSH2を使用してサーバ上でコマンドを実行する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_exec as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
String orionssh2_exec(String host, String user, 
  String password, String cmd)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( cmd == null ){
    throw new Exception("cmd is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  Session sess = null;
  String result = null;

  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // コマンド実行
    sess = conn.openSession();
    sess.execCommand(cmd);
    // 標準出力
    BufferedReader stdout = new BufferedReader(
      new InputStreamReader(
        new StreamGobbler(sess.getStdout()), "UTF-8"));
    StringBuffer sbuf = new StringBuffer();
    String line = "";
    while((line = stdout.readLine()) != null ){
      sbuf.append(line);
      sbuf.append("\n");
    }
    result = sbuf.toString();
  }
  finally
  {
    if( sess != null )sess.close();
    if( conn != null )conn.close();
  }

  return result;
}
$$

実行例

select orionssh2_exec(
  '192.168.1.25',
  'user', 'password',
  'ls -alF')

※以下のjarをCLASSPATH環境変数に追加
orion-ssh2-214.jar

動作環境
JDK6 Update23, H2 Database 1.2.149 (2011-01-07)

関連情報
H2 Database上でOrion SSH2を使用するユーザー定義関数のまとめ

H2 DatabaseとTwitter4Jを使用してフォローしている数を取得する関数を作成する

2011-02-16T10:49:00.002+09:00

H2 DatabaseとTwitter4Jを使用してフォローしている数を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists twitter_get_num_friends as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import twitter4j.*;
import twitter4j.http.*;
import twitter4j.conf.*;
@CODE
Integer twitter_get_num_friends(String consumerKey, 
  String consumerSecret, String accessToken,
  String accessTokenSecret)
  throws Exception
{
  if( consumerKey == null ){
    throw new Exception("consumerKey is not specified.");
  }
  if( consumerSecret == null ){
    throw new Exception("consumerSecret is not specified.");
  }
  if( accessToken == null ){
    throw new Exception("accessToken is not specified.");
  }
  if( accessTokenSecret == null ){
    throw new Exception("accessTokenSecret is not specified.");
  }

  Properties prop = new Properties();
  prop.put("oauth.consumerKey", consumerKey);
  prop.put("oauth.consumerSecret", consumerSecret);
  prop.put("oauth.accessToken", accessToken);
  prop.put("oauth.accessTokenSecret", accessTokenSecret);
  PropertyConfiguration pc = 
     new PropertyConfiguration(prop);

  OAuthAuthorization oauth = new OAuthAuthorization(pc);
  TwitterFactory tf = new TwitterFactory();
  Twitter twitter = tf.getInstance(oauth);
  return new Integer(twitter.getAccountTotals().getFriends());
}
$$

実行例

select twitter_get_num_friends('xxxx',
'xxxx',
'xxxx',
'xxxx');

H2 DatabaseとJRedisで指定したkeyが存在するかどうかを返す関数を作成する

2011-02-16T10:08:00.001+09:00

H2 DatabaseとJRedisで指定したkeyが存在するかどうかを返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_exists as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
boolean jredis_exists(String host, Integer intPort, 
  String key)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  return jrc.exists(key);
}
$$

実行例

select jredis_exists('192.168.1.25', 6379, 'key1');
select jredis_exists('192.168.1.25', 6379, 'not_exist');

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとOrion SSH2を使用してBLOBをSFTP上へアップロードする関数を作成する

2011-02-15T10:01:00.003+09:00

H2 DatabaseとOrion SSH2を使用してBLOBをSFTP上へアップロードする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_put_binary as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
Integer orionssh2_put_binary(String host, String user, 
  String password, String path, Blob blob)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null ){
    throw new Exception("path is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;

  InputStream bis = null;
  SFTPv3FileHandle fh = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ファイルをアップロード
    fh = sftpc.createFile(path);
    bis = blob.getBinaryStream();
    byte buf[] = new byte[8192];
    long fo = 0;
    int sz = 0;
    while((sz = bis.read(buf, 0, 8192)) != -1){
      sftpc.write(fh, fo, buf, 0, sz);
      fo += sz;
    }

  }
  finally
  {
    if( bis != null )bis.close();
    if( fh != null )sftpc.closeFile(fh);
    if( sftpc != null )sftpc.close();
    if( conn != null )conn.close();
  }

  return new Integer(0);
}
$$

実行例

drop table if exists blobtest;
create table blobtest (c1 numeric(4), c2 blob);
insert into blobtest values (1, 
  orionssh2_get_binary(
  '192.168.1.25',
  'user', 'password',
  'sf.png')
);
select orionssh2_put_binary(
  '192.168.1.25',
  'user', 'password',
  'upload.png', c2)
from blobtest 
where c1 = 1;

H2 DatabaseとTwitter4Jを使用してフォロワー数を取得する関数を作成する

2011-02-14T10:35:00.001+09:00

H2 DatabaseとTwitter4Jを使用してフォロワー数を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists twitter_get_num_followers as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import twitter4j.*;
import twitter4j.http.*;
import twitter4j.conf.*;
@CODE
Integer twitter_get_num_followers(String consumerKey, 
  String consumerSecret, String accessToken,
  String accessTokenSecret)
  throws Exception
{
  if( consumerKey == null ){
    throw new Exception("consumerKey is not specified.");
  }
  if( consumerSecret == null ){
    throw new Exception("consumerSecret is not specified.");
  }
  if( accessToken == null ){
    throw new Exception("accessToken is not specified.");
  }
  if( accessTokenSecret == null ){
    throw new Exception("accessTokenSecret is not specified.");
  }

  Properties prop = new Properties();
  prop.put("oauth.consumerKey", consumerKey);
  prop.put("oauth.consumerSecret", consumerSecret);
  prop.put("oauth.accessToken", accessToken);
  prop.put("oauth.accessTokenSecret", accessTokenSecret);
  PropertyConfiguration pc = 
     new PropertyConfiguration(prop);

  OAuthAuthorization oauth = new OAuthAuthorization(pc);
  TwitterFactory tf = new TwitterFactory();
  Twitter twitter = tf.getInstance(oauth);
  return new Integer(twitter.getAccountTotals().getFollowers());
}
$$

実行例

select twitter_get_num_followers('xxxx',
'xxxx',
'xxxx',
'xxxx');

H2 DatabaseとOrion SSH2を使用してSFTPでファイルをダウンロードしてBLOBとして返す関数を作成する

2011-02-13T10:55:00.003+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでファイルをダウンロードしてBLOBとして返す関数を作成するには、以下の手順を実行します。

1.以下のソースファイルをantなどでコンパイルします。
Orionssh2GetBinaryFunction.java

package com.serverarekore.h2;
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;

public class Orionssh2GetBinaryFunction
{
  static public InputStream orionssh2_get_binary(String host, 
    String user, String password, String path)
    throws Exception
  {
    if( host == null ){
      throw new Exception("server is not specified.");
    }
    if( user == null ){
      throw new Exception("user is not specified.");
    }
    if( password == null )password = "";
    if( path == null ){
      throw new Exception("path is not specified.");
    }

    com.trilead.ssh2.Connection conn = null;
    SFTPv3Client sftpc = null;

    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ファイルをダウンロード
    final File tf = File.createTempFile("lobtmp", null);
    SFTPv3FileHandle fh = sftpc.openFileRO(path);

    BufferedOutputStream bos = new BufferedOutputStream(
      new FileOutputStream(tf));
    byte buf[] = new byte[8192];
    long fo = 0;
    int sz = 0;
    while((sz = sftpc.read(fh, fo, buf, 0, 8192)) != -1){
      bos.write(buf, 0, sz);
      fo += sz;
    }
    sftpc.closeFile(fh);
    bos.flush();
    bos.close();

    InputStream ris = new InputStream(){
      private final InputStream fis = new FileInputStream(tf);
      private boolean deleted = false;
      private final File fn = tf;
      public int autoDelete(int sz) throws IOException
      {
        if(sz < 0 ){
          close();
        }
        return sz;
      }
      public void close() throws IOException
      {
        if( !deleted ){
          fis.close();
          fn.delete();
          deleted = true;
        }
      }
      public int read(byte buf[], int off, int len) throws IOException
      {
        return deleted?-1:autoDelete(fis.read(buf, off, len));
      }

      public int read(byte buf[]) throws IOException
      {
        return deleted?-1:autoDelete(fis.read(buf));
      }

      public int read() throws IOException 
      {
        return deleted?-1:autoDelete(fis.read());
      }
    };

    return ris;
  } 
}

build.xmlのサンプル

<project name="H2Functions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
    <pathelement location="c:/Program Files/H2/bin/h2-1.3.149.jar"/>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:/share/jars/Orionssh2GetBinary.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

2.システム環境変数CLASSPATHにコンパイルしてできたOrionssh2GetBinary.jarを追加し、
H2 Databaseのサービスを再起動。

3.H2 Consoleから以下のコマンドを実行して、ファンクション作成。

create alias orionssh2_get_binary for 
"com.serverarekore.h2.Orionssh2GetBinaryFunction.orionssh2_get_binary";

4.以下のようなSQLでSFTP上のファイルをBLOBに格納できます。

drop table if exists blobtest;
create table blobtest (c1 numeric(4), c2 blob);
insert into blobtest values (1, 
  orionssh2_get_binary(
  '192.168.1.25',
  'user', 'password',
  'sf.png')
);

H2 DatabaseとTwitter4Jを使用してお気に入りの数を取得する関数を作成する

2011-02-12T10:50:00.001+09:00

H2 DatabaseとTwitter4Jを使用してお気に入りの数を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists twitter_get_favorites as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import twitter4j.*;
import twitter4j.http.*;
import twitter4j.conf.*;
@CODE
Integer twitter_get_favorites(String consumerKey, 
  String consumerSecret, String accessToken,
  String accessTokenSecret)
  throws Exception
{
  if( consumerKey == null ){
    throw new Exception("consumerKey is not specified.");
  }
  if( consumerSecret == null ){
    throw new Exception("consumerSecret is not specified.");
  }
  if( accessToken == null ){
    throw new Exception("accessToken is not specified.");
  }
  if( accessTokenSecret == null ){
    throw new Exception("accessTokenSecret is not specified.");
  }

  Properties prop = new Properties();
  prop.put("oauth.consumerKey", consumerKey);
  prop.put("oauth.consumerSecret", consumerSecret);
  prop.put("oauth.accessToken", accessToken);
  prop.put("oauth.accessTokenSecret", accessTokenSecret);
  PropertyConfiguration pc = 
     new PropertyConfiguration(prop);

  OAuthAuthorization oauth = new OAuthAuthorization(pc);
  TwitterFactory tf = new TwitterFactory();
  Twitter twitter = tf.getInstance(oauth);
  return new Integer(twitter.getAccountTotals().getFavorites());
}
$$

実行例

select twitter_get_favorites('xxxx',
'xxxx',
'xxxx',
'xxxx');

H2 DatabaseとJRedisで指定したkeyのvalueを取得する関数を作成する

2011-02-11T15:42:00.001+09:00

H2 DatabaseとJRedisで指定したkeyのvalueを取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_get as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
String jredis_get(String host, Integer intPort, 
  String key)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  byte result[] = jrc.get(key);
  return result==null?null:DefaultCodec.toStr(result);
}
$$

実行例

select jredis_get('192.168.1.25', 6379, 'key1')

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

H2 DatabaseとOrion SSH2を使用してSFTPでファイルを移動・リネームする関数を作成する

2011-02-11T10:19:00.002+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでファイルを移動・リネームする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_mv as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
Integer orionssh2_mv(String host, String user, 
  String password, String path1, String path2)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path1 == null ){
    throw new Exception("path1 is not specified.");
  }
  if( path2 == null ){
    throw new Exception("path2 is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  String result = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ファイルを移動・リネーム
    sftpc.mv(path1, path2);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return new Integer(0);
}
$$

実行例

select orionssh2_mv('192.168.1.25', 'user', 'password', 'sf.png', './test/sf2.png')

H2 DatabaseとTwitter4Jを使用してツィート回数を取得する関数を作成する

2011-02-10T10:34:00.002+09:00

H2 DatabaseとTwitter4Jを使用してツィート回数を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists twitter_get_updates as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import twitter4j.*;
import twitter4j.http.*;
import twitter4j.conf.*;
@CODE
Integer twitter_get_updates(String consumerKey, 
  String consumerSecret, String accessToken,
  String accessTokenSecret)
  throws Exception
{
  if( consumerKey == null ){
    throw new Exception("consumerKey is not specified.");
  }
  if( consumerSecret == null ){
    throw new Exception("consumerSecret is not specified.");
  }
  if( accessToken == null ){
    throw new Exception("accessToken is not specified.");
  }
  if( accessTokenSecret == null ){
    throw new Exception("accessTokenSecret is not specified.");
  }

  Properties prop = new Properties();
  prop.put("oauth.consumerKey", consumerKey);
  prop.put("oauth.consumerSecret", consumerSecret);
  prop.put("oauth.accessToken", accessToken);
  prop.put("oauth.accessTokenSecret", accessTokenSecret);
  PropertyConfiguration pc = 
     new PropertyConfiguration(prop);

  OAuthAuthorization oauth = new OAuthAuthorization(pc);
  TwitterFactory tf = new TwitterFactory();
  Twitter twitter = tf.getInstance(oauth);
  return new Integer(twitter.getAccountTotals().getUpdates());
}
$$

実行例

select twitter_get_updates('xxxx',
'xxxx',
'xxxx',
'xxxx');

H2 DatabaseとOrion SSH2を使用してSFTPでフルパスを取得する関数を作成する

2011-02-09T10:10:00.002+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでフルパスを取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_get_fullpath as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
String orionssh2_get_fullpath(String host, String user, 
  String password, String path)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null ){
    throw new Exception("path is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  String result = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // フルパスを取得
    result = sftpc.canonicalPath(path);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return result;
}
$$

実行例

select orionssh2_get_fullpath('192.168.1.25', 'user', 'password', 'sf.png')

H2 DatabaseとTwitter4Jを使用してユーザー名を取得する関数を作成する

2011-02-08T10:27:00.001+09:00

H2 DatabaseとTwitter4Jを使用してユーザー名を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists twitter_get_screen_name as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import twitter4j.*;
import twitter4j.http.*;
import twitter4j.conf.*;
@CODE
String twitter_get_screen_name(String consumerKey, 
  String consumerSecret, String accessToken,
  String accessTokenSecret)
  throws Exception
{
  if( consumerKey == null ){
    throw new Exception("consumerKey is not specified.");
  }
  if( consumerSecret == null ){
    throw new Exception("consumerSecret is not specified.");
  }
  if( accessToken == null ){
    throw new Exception("accessToken is not specified.");
  }
  if( accessTokenSecret == null ){
    throw new Exception("accessTokenSecret is not specified.");
  }

  Properties prop = new Properties();
  prop.put("oauth.consumerKey", consumerKey);
  prop.put("oauth.consumerSecret", consumerSecret);
  prop.put("oauth.accessToken", accessToken);
  prop.put("oauth.accessTokenSecret", accessTokenSecret);
  PropertyConfiguration pc = 
     new PropertyConfiguration(prop);

  OAuthAuthorization oauth = new OAuthAuthorization(pc);
  TwitterFactory tf = new TwitterFactory();
  Twitter twitter = tf.getInstance(oauth);
  return twitter.getScreenName();
}
$$

実行例

select twitter_get_screen_name('xxxx',
'xxxx',
'xxxx',
'xxxx');

H2 DatabaseとOrion SSH2を使用してSFTPでシンボリックリンクのターゲットを表示する関数を作成する

2011-02-07T10:03:00.002+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでシンボリックリンクのターゲットを表示する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_read_link as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
String orionssh2_read_link(String host, String user, 
  String password, String path)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null ){
    throw new Exception("path is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  String result = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // シンボリックリンクのターゲットを取得
    result = sftpc.readLink(path);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return result;
}
$$

実行例

select orionssh2_read_link('192.168.1.25', 'user', 'password', 'symlink_sf.png')

H2 DatabaseとJRedisでkey-valueを設定する関数を作成する

2011-02-06T22:39:00.001+09:00

H2 DatabaseとJRedisでkey-valueを設定する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jredis_set as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import org.jredis.ri.alphazero.*;
import org.jredis.ri.alphazero.support.*;
@CODE
Integer jredis_set(String host, Integer intPort, 
  String key, String value)
  throws Exception
{
  if( host == null ){
    throw new Exception("host is not specified.");
  }
  int port = 6379;
  if( intPort != null ){
    port = intPort.intValue();
  }
  if( key == null ){
    throw new Exception("key is not specified.");
  }
  if( value == null ){
    throw new Exception("value is not specified.");
  }

  JRedisClient jrc = new JRedisClient(host, port);
  jrc.set(key, value);
  return new Integer(0);
}
$$

実行例

select jredis_set('192.168.1.25', 6379, 'key1', 'test')

※以下のjarをCLASSPATH環境変数に追加
jredis-core-all-a.0-SNAPSHOT-jar-with-dependencies.jar

動作環境
JDK6 Update23, H2 Database 1.3.149 (2011-01-07), JRedis2.0.0

Apache Derbyで指定されたパスのファイルを列挙する関数を作成する

2011-02-06T10:34:00.001+09:00

Apache Derbyで指定されたパスのファイルを列挙する関数を作成するには、以下の手順を実行します。

1.以下のクラスをantでコンパイルします。
FsListFunction.java

package com.serverarekore.derby;
import java.io.*;
import java.sql.*;
import java.net.*;
// SimpleResultSetのため
import org.h2.tools.*;

public class FsListFunction
{
  public static ResultSet fs_list(String path)
  {
    if( path == null )return null;
    File file = new File(path);
    SimpleResultSet rs = new SimpleResultSet();
    rs.addColumn("NAME", Types.VARCHAR, 1024, 0);
    String files[] = file.list();
    for(int fi=0;fi<files.length;fi++){
      rs.addRow(files[fi]);
    }

    return rs;
  }
}

build.xmlファイル例

<project name="DerbyFunctions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:\share\derby_funcs\FsListFunction.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

※libディレクトリにH2 DatabaseのSimpleResultSetクラスを使用するために
h2-1.3.149.jarをコピーしておきます。

2.derbyにjarをインストール

call sqlj.install_jar('c:\share\derby_funcs\h2-1.3.149.jar', 'APP.func9', 0);
call sqlj.install_jar('c:\share\derby_funcs\FsListFunction.jar', 'APP.func10', 0);

3.クラスパスに通す

call syscs_util.syscs_set_database_property('derby.database.classpath', 
'APP.func9:APP.func10');

4.関数を作成

CREATE FUNCTION fs_list(path varchar(1024))
RETURNS TABLE
(
  NAME      VARCHAR(1024)
)
LANGUAGE JAVA
PARAMETER STYLE DERBY_JDBC_RESULT_SET
READS SQL DATA
EXTERNAL NAME 'com.serverarekore.derby.FsListFunction.fs_list';

5.実行

select * from table( fs_list('c:\') ) files;

動作環境
Apache Derby 10.7.1.1, JDK6 Update23, h2-1.3.149

H2 DatabaseとOrion SSH2を使用してSFTPでディレクトリを削除する関数を作成する

2011-02-05T10:56:00.002+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでディレクトリを削除する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_rmdir as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
Integer orionssh2_rmdir(String host, String user, 
  String password, String path)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null ){
    throw new Exception("path is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ディレクトリ削除
    sftpc.rmdir(path);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return new Integer(0);
}
$$

実行例

select orionssh2_rmdir('192.168.1.25', 'user', 'password', 'test_dir')

Apache Derbyで指定されたファイルのサイズを返す関数を作成する

2011-02-04T10:48:00.000+09:00

Apache Derbyで指定されたファイルのサイズを返す関数を作成するには、以下の手順を実行します。

1.以下のクラスをantでコンパイルします。
FsLengthFunction.java

package com.serverarekore.derby;
import java.io.*;
import java.sql.*;
import java.net.*;

public class FsLengthFunction
{
  public static Long fs_length(String path)
  {
    if( path == null )return null;
    File file = new File(path);
    return new Long(file.length());
  }
}

build.xmlファイル例

<project name="DerbyFunctions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:\share\derby_funcs\FsLengthFunction.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

2.derbyにjarをインストール

call sqlj.install_jar('c:\share\derby_funcs\FsLengthFunction.jar', 'APP.func8', 0);

3.クラスパスに通す

call syscs_util.syscs_set_database_property('derby.database.classpath', 'APP.func8');

※複数のjarの場合は'APP.func1:APP.func2'のように「:」で区切る。

4.関数を作成

create function fs_length(path varchar(1024)) 
returns bigint
parameter style java no sql language java
external name 'com.serverarekore.derby.FsLengthFunction.fs_length';

5.実行

select fs_length('c:\share\test.txt') from sysibm.sysdummy1;

動作環境
Apache Derby 10.7.1.1, JDK6 Update23

H2 DatabaseとOrion SSH2を使用してSFTPでディレクトリを作成する関数を作成する

2011-02-03T10:42:00.002+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでディレクトリを作成する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_mkdir as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
Integer orionssh2_mkdir(String host, String user, 
  String password, String path, Integer permission)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null ){
    throw new Exception("path is not specified.");
  }
  if( permission == null ){
    throw new Exception("permission is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ディレクトリ作成
    sftpc.mkdir(path, permission);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return new Integer(0);
}
$$

実行例

select orionssh2_mkdir('192.168.1.25', 'user', 'password', 'test_dir', 0x777)

Apache Derbyで指定されたパスの最終更新日時を返す関数を作成する

2011-02-02T10:11:00.000+09:00

Apache Derbyで指定されたパスの最終更新日時を返す関数を作成するには、以下の手順を実行します。

1.以下のクラスをantでコンパイルします。
FsLastModifiedFunction.java

package com.serverarekore.derby;
import java.io.*;
import java.sql.*;
import java.net.*;

public class FsLastModifiedFunction
{
  public static Timestamp fs_last_modified(String path)
  {
    if( path == null )return null;
    File file = new File(path);
    return new Timestamp(file.lastModified());
  }
}

build.xmlファイル例

<project name="DerbyFunctions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:\share\derby_funcs\FsLastModifiedFunction.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

2.derbyにjarをインストール

call sqlj.install_jar('c:\share\derby_funcs\FsLastModifiedFunction.jar', 'APP.func7', 0);

3.クラスパスに通す

call syscs_util.syscs_set_database_property('derby.database.classpath', 'APP.func7');

※複数のjarの場合は'APP.func1:APP.func2'のように「:」で区切る。

4.関数を作成

create function fs_last_modified(path varchar(1024)) 
returns timestamp
parameter style java no sql language java
external name 'com.serverarekore.derby.FsLastModifiedFunction.fs_last_modified';

5.実行

select fs_last_modified('c:\share\test.txt') from sysibm.sysdummy1;

H2 DatabaseとOrion SSH2を使用してSFTPでファイルのパーミッションを取得する関数を作成する

2011-02-01T10:32:00.003+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでファイルのパーミッションを取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_get_permissions as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
String orionssh2_get_permissions(String host, String user, 
  String password, String path)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null ){
    throw new Exception("path is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  SFTPv3FileAttributes fa = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ファイルの情報を取得
    fa = sftpc.lstat(path);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return fa.getOctalPermissions();
}
$$

実行例

select orionssh2_get_permissions('192.168.1.25', 'user', 'password', './sf.png')

Apache Derbyで指定されたパスの親ディレクトリを返す関数を作成する

2011-01-31T10:00:00.000+09:00

Apache Derbyで指定されたパスの親ディレクトリを返す関数を作成するには、以下の手順を実行します。

1.以下のクラスをantでコンパイルします。
FsGetParentFunction.java

package com.serverarekore.derby;
import java.io.*;
import java.sql.*;
import java.net.*;

public class FsGetParentFunction
{
  public static String fs_get_parent(String path)
  {
    if( path == null )return null;
    File file = new File(path);
    return file.getParent();
  }
}

build.xmlファイル例

<project name="DerbyFunctions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:\share\derby_funcs\FsGetParentFunction.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

2.derbyにjarをインストール

call sqlj.install_jar('c:\share\derby_funcs\FsGetParentFunction.jar', 'APP.func6', 0);

3.クラスパスに通す

call syscs_util.syscs_set_database_property('derby.database.classpath', 'APP.func6');

※複数のjarの場合は'APP.func1:APP.func2'のように「:」で区切る。

4.関数を作成

create function fs_get_parent(path varchar(1024)) 
returns varchar(1024)
parameter style java no sql language java
external name 'com.serverarekore.derby.FsGetParentFunction.fs_get_parent';

5.実行

select fs_get_parent('c:\windows\windows.ini') from sysibm.sysdummy1;

H2 DatabaseとOrion SSH2を使用してSFTPでファイルのGIDを取得する関数を作成する

2011-01-30T10:25:00.003+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでファイルのGIDを取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_get_gid as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
Integer orionssh2_get_gid(String host, String user, 
  String password, String path)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null ){
    throw new Exception("path is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  SFTPv3FileAttributes fa = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ファイルの情報を取得
    fa = sftpc.lstat(path);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return new Integer(fa.gid);
}
$$

実行例

select orionssh2_get_gid('192.168.1.25', 'user', 'password', './sf.png')

Apache Derbyで指定されたパスがディレクトリかどうかを返す関数を作成する

2011-01-29T10:43:00.000+09:00

Apache Derbyで指定されたパスがディレクトリかどうかを返す関数を作成するには、以下の手順を実行します。

1.以下のクラスをantでコンパイルします。
FsIsDirectoryFunction.java

package com.serverarekore.derby;
import java.io.*;
import java.sql.*;
import java.net.*;

public class FsIsDirectoryFunction
{
  public static Integer fs_is_directory(String path)
  {
    if( path == null )return null;
    File file = new File(path);
    return new Integer(file.isDirectory()?1:0);
  }
}

build.xmlファイル例

<project name="DerbyFunctions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:\share\derby_funcs\FsIsDirectoryFunction.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

2.derbyにjarをインストール

call sqlj.install_jar('c:\share\derby_funcs\FsIsDirectoryFunction.jar', 'APP.func5', 0);

3.クラスパスに通す

call syscs_util.syscs_set_database_property('derby.database.classpath', 'APP.func5');

※複数のjarの場合は'APP.func1:APP.func2'のように「:」で区切る。

4.関数を作成

create function fs_is_directory(path varchar(1024)) returns int
parameter style java no sql language java
external name 'com.serverarekore.derby.FsIsDirectoryFunction.fs_is_directory';

5.実行

select fs_is_directory('c:\windows'), 
fs_is_directory('c:\windows\windows.ini') from sysibm.sysdummy1;

動作環境
Apache Derby 10.7.1.1, JDK6 Update23

H2 DatabaseとOrion SSH2を使用してSFTPでファイルのUIDを取得する関数を作成する

2011-01-28T10:20:00.002+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでファイルのUIDを取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_get_uid as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
Integer orionssh2_get_uid(String host, String user, 
  String password, String path)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null ){
    throw new Exception("path is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  SFTPv3FileAttributes fa = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ファイルの情報を取得
    fa = sftpc.lstat(path);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return new Integer(fa.uid);
}
$$

実行例

select orionssh2_get_uid('192.168.1.25', 'user', 'password', './sf.png')

Apache Derbyで指定されたパスが絶対パスかどうかを返す関数を作成する

2011-01-27T10:26:00.001+09:00

Apache Derbyで指定されたパスが絶対パスかどうかを返す関数を作成するには、以下の手順を実行します。

1.以下のクラスをantでコンパイルします。
FsIsAbsoluteFunction.java

package com.serverarekore.derby;
import java.io.*;
import java.sql.*;
import java.net.*;

public class FsIsAbsoluteFunction
{
  public static Integer fs_is_absolute(String path)
  {
    if( path == null )return null;
    File file = new File(path);
    return new Integer(file.isAbsolute()?1:0);
  }
}

build.xmlファイル例

<project name="FsIsAbsoluteFunctions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:\share\derby_funcs\FsIsAbsoluteFunction.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

2.derbyにjarをインストール

call sqlj.install_jar('c:\share\derby_funcs\FsIsAbsoluteFunction.jar', 'APP.func4', 0);

3.クラスパスに通す

call syscs_util.syscs_set_database_property('derby.database.classpath', 'APP.func4');

※複数のjarの場合は'APP.func1:APP.func2'のように「:」で区切る。

4.関数を作成

create function fs_is_absolute(path varchar(1024)) returns int
parameter style java no sql language java
external name 'com.serverarekore.derby.FsIsAbsoluteFunction.fs_is_absolute';

5.実行

select fs_is_absolute('c:\'), 
fs_is_absolute('.\test.txt') from sysibm.sysdummy1;

H2 DatabaseとOrion SSH2を使用してSFTPでファイルの最終更新日時を取得する関数を作成する

2011-01-26T10:01:00.002+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでファイルの最終更新日時を取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_get_mtime as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
java.sql.Timestamp orionssh2_get_mtime(String host, String user, 
  String password, String path)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null ){
    throw new Exception("path is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  SFTPv3FileAttributes fa = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ファイルの情報を取得
    fa = sftpc.lstat(path);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return new java.sql.Timestamp(fa.mtime*1000);
}
$$

実行例

select orionssh2_get_mtime('192.168.1.25', 'user', 'password', './sf.png')

Apache Derbyで指定されたパスのパーティション/ドライブ容量を返す関数を作成する

2011-01-25T10:45:00.000+09:00

Apache Derbyで指定されたパスのパーティション/ドライブ容量を返す関数を作成するには、以下の手順を実行します。

1.以下のクラスをantでコンパイルします。
FsGetTotalSpaceFunction.java

package com.serverarekore.derby;
import java.io.*;
import java.sql.*;
import java.net.*;

public class FsGetTotalSpaceFunction
{
  public static Long fs_get_total_space(String path)
  {
    if( path == null )return null;
    File file = new File(path);
    return new Long(file.getTotalSpace());
  }
}

build.xmlファイル例

<project name="DerbyFunctions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:\share\derby_funcs\FsGetTotalSpaceFunction.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

2.derbyにjarをインストール

call sqlj.install_jar('c:\share\derby_funcs\FsGetTotalSpaceFunction.jar', 'APP.func3', 0);

3.クラスパスに通す

call syscs_util.syscs_set_database_property('derby.database.classpath', 'APP.func3');

※複数のjarの場合は'APP.func1:APP.func2'のように「:」で区切る。

4.関数を作成

create function fs_get_total_space(path varchar(1024)) returns bigint
parameter style java no sql language java
external name 'com.serverarekore.derby.FsGetTotalSpaceFunction.fs_get_total_space';

5.実行

select fs_get_total_space('c:\') from sysibm.sysdummy1;

H2 DatabaseとOrion SSH2を使用してSFTPでファイルのサイズを取得する関数を作成する

2011-01-24T10:32:00.002+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでファイルのサイズを取得する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_get_size as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
Long orionssh2_get_size(String host, String user, 
  String password, String path)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null ){
    throw new Exception("path is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  SFTPv3FileAttributes fa = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ファイルの情報を取得
    fa = sftpc.lstat(path);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return fa.size;
}
$$

実行例

select orionssh2_get_size('192.168.1.25', 'user', 'password', './sf.png')

Apache Derbyで指定された時間スリープする関数を作成する

2011-01-23T10:28:00.000+09:00

Apache Derbyで指定された時間スリープする関数を作成するには、以下の手順を実行します。

1.以下のクラスをantでコンパイルします。
SleepFunction.java

package com.serverarekore.derby;
import java.io.*;
import java.sql.*;
import java.net.*;

public class SleepFunction
{
  public static Long sleep(Long millis)
    throws Exception 
  {
    Thread.sleep(millis);
    return millis;
  } 
}

build.xmlファイル例

<project name="DerbyFunctions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:\share\derby_funcs\SleepFunction.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

2.derbyにjarをインストール

call sqlj.install_jar('c:\share\derby_funcs\SleepFunction.jar', 'APP.func2', 0);

3.クラスパスに通す

call syscs_util.syscs_set_database_property('derby.database.classpath', 'APP.func2');

※複数のjarの場合は'APP.func1:APP.func2'のように「:」で区切る。
4.関数を作成

create function sleep(millis bigint) returns bigint
parameter style java no sql language java
external name 'com.serverarekore.derby.SleepFunction.sleep';

5.実行

select sleep(5000) from sysibm.sysdummy1;

H2 DatabaseとTwitter4Jを使用してツィートする関数を作成する

2011-01-23T02:10:00.002+09:00

H2 DatabaseとTwitter4Jを使用してツィートする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists twitter_update_status as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import twitter4j.*;
import twitter4j.http.*;
import twitter4j.conf.*;
@CODE
Long twitter_update_status(String consumerKey, 
  String consumerSecret, String accessToken,
  String accessTokenSecret, String message)
  throws Exception
{
  if( consumerKey == null ){
    throw new Exception("consumerKey is not specified.");
  }
  if( consumerSecret == null ){
    throw new Exception("consumerSecret is not specified.");
  }
  if( accessToken == null ){
    throw new Exception("accessToken is not specified.");
  }
  if( accessTokenSecret == null ){
    throw new Exception("accessTokenSecret is not specified.");
  }
  if( message == null ){
    throw new Exception("message is not specified.");
  }

  Properties prop = new Properties();
  prop.put("oauth.consumerKey", consumerKey);
  prop.put("oauth.consumerSecret", consumerSecret);
  prop.put("oauth.accessToken", accessToken);
  prop.put("oauth.accessTokenSecret", accessTokenSecret);
  PropertyConfiguration pc = 
     new PropertyConfiguration(prop);

  OAuthAuthorization oauth = new OAuthAuthorization(pc);
  TwitterFactory tf = new TwitterFactory();
  Twitter twitter = tf.getInstance(oauth);
  Status status = twitter.updateStatus(message);
  return status.getId();
}
$$

実行例

select twitter_update_status('xxxx',
'xxxx',
'xxxx',
'xxxx',
'H2Databaseテスト');

H2 DatabaseとOrion SSH2を使用してSFTPでシンボリックリンクを作成する関数を作成する

2011-01-22T10:17:00.004+09:00

H2 DatabaseとOrion SSH2を使用してSFTPでシンボリックリンクを作成する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_create_symlink as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
Integer orionssh2_create_symlink(String host, String user, 
  String password, String path1, String path2)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path1 == null ){
    throw new Exception("path1 is not specified.");
  }
  if( path2 == null ){
    throw new Exception("path2 is not specified.");
  }

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // シンボリックリンク作成
    sftpc.createSymlink(path1, path2);
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return new Integer(0);
}
$$

実行例

select orionssh2_create_symlink('192.168.1.25', 
'user', 'password', './symlink_sf.png', './sf.png')

Apache Derbyでドライブの空き容量を返す関数を作成する

2011-01-21T10:59:00.001+09:00

Apache Derbyでドライブの空き容量を返す関数を作成するには、以下の手順を実行します。

1.以下のクラスをantでコンパイルします。
FsGetFreeSpaceFunction.java

package com.serverarekore.derby;
import java.io.*;
import java.sql.*;
import java.net.*;

public class FsGetFreeSpaceFunction
{
  public static Long fs_get_free_space(String path)
  {
    if( path == null )return null;
    File file = new File(path);
    return new Long(file.getFreeSpace());
  }
}

build.xmlファイル例

<project name="DerbyFunctions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:\share\derby_funcs\FsGetFreeSpaceFunction.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

2.derbyにjarをインストール

call sqlj.install_jar('c:\share\derby_funcs\FsGetFreeSpaceFunction.jar', 'APP.func1', 0);

3.クラスパスに通す

call syscs_util.syscs_set_database_property('derby.database.classpath', 
'APP.func1');

4.関数を作成

create function fs_get_free_space(path varchar(1024)) returns bigint
parameter style java no sql language java
external name 'com.serverarekore.derby.FsGetFreeSpaceFunction.fs_get_free_space';

5.実行

select fs_get_free_space('c:\') from sysibm.sysdummy1;

動作環境
Apache Derby 10.7.1.1, JDK6 Update23

H2 DatabaseとOrion SSH2でサーバ上のファイルを列挙する関数を作成する

2011-01-20T10:47:00.003+09:00

H2 DatabaseとOrion SSH2でサーバ上のファイルを列挙する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists orionssh2_list_files as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import java.net.*;
import com.trilead.ssh2.*;
@CODE
ResultSet orionssh2_list_files(String host, String user, 
  String password, String path)
  throws Exception
{
  if( host == null ){
    throw new Exception("server is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( password == null )password = "";
  if( path == null )path = ".";

  SimpleResultSet rs = new SimpleResultSet();
  rs.addColumn("PATH", Types.VARCHAR, 1024, 0);

  com.trilead.ssh2.Connection conn = null;
  SFTPv3Client sftpc = null;
  try
  {
    // サーバに接続
    conn = new com.trilead.ssh2.Connection(host);
    conn.connect();
    if( !conn.authenticateWithPassword(user, password) ){
      throw new Exception("authentication failed.");
    }

    // SFTP client作成
    sftpc = new SFTPv3Client(conn);
    sftpc.setCharset("UTF-8");

    // ファイル列挙
    Vector files = sftpc.ls(path);
    for(int fi=0;fi<files.size();fi++){
      SFTPv3DirectoryEntry dirent = 
        (SFTPv3DirectoryEntry)files.get(fi);
      rs.addRow(dirent.filename);
    }
  }
  finally
  {
    if( sftpc != null )sftpc.close();
    if( sftpc != null )conn.close();
  }
  return rs;
}
$$

実行例

select * from orionssh2_list_files('192.168.1.25', 'user', 'password', '.')

UbuntuでCurlFtpFSを使用して、FTPサーバ上のディレクトリをマウントする

2011-01-19T10:05:00.000+09:00

UbuntuでCurlFtpFSを使用して、FTPサーバ上のディレクトリをマウントするには、以下の手順を実行します。

1.CurlFtpFSのインストール
sudo apt-get install curlftpfs

2.FTPサーバ上のディレクトリのマウント
mkdir ~/ftp
curlftpfs -o user=user1:pass ftp://192.168.1.122/ ~/ftp
ls ~/ftp

3.アンマウント
fusermount -u ~/ftp

動作環境
Ubuntu 10.10

H2 DatabaseとHadoopでBLOBをHDFS上にアップロードする関数を作成する

2011-01-18T10:51:00.001+09:00

H2 DatabaseとHadoopでBLOBをHDFS上にアップロードする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists hdfs_put_binary as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import org.apache.hadoop.conf.*;
import org.apache.hadoop.fs.*;
import java.net.*;
@CODE
Integer hdfs_put_binary(String uri, String user, 
  String path, Blob blob)
  throws Exception
{
  if( uri == null ){
    throw new Exception("uri is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( path == null ){
    throw new Exception("path is not specified.");
  }
  if( blob == null ){
    throw new Exception("blob is not specified.");
  }

  FileSystem fs = FileSystem.get(
    URI.create(uri), new Configuration(), user);

  FSDataOutputStream fos = null;
  InputStream bis = null;
  byte buf[] = new byte[8192];
  int rs = 0;
  try
  {
    bis = blob.getBinaryStream();
    fos = fs.create(new Path(path));
    while( (rs = bis.read(buf)) != -1 ){
      fos.write(buf, 0, rs);
    }
    fos.flush();
  }
  finally
  {
    if( bis != null )bis.close();
    if( fos != null )fos.close();
  }

  return new Integer(0);
}
$$

実行例

drop table if exists blobtest;
create table blobtest (c1 numeric(4), c2 blob);
insert into blobtest values (1, 
  hdfs_get_binary(
  'hdfs://192.168.1.81:9000/',
  'hadoop', '/opt/hadoop-data/SF.JPG')
);
select hdfs_put_binary(
  'hdfs://192.168.1.81:9000/',
  'hadoop', '/opt/hadoop-data/SF_bak.JPG', c2)
from blobtest 
where c1 = 1;

※以下のjarをCLASSPATH環境変数に追加
hadoop-common-0.21.0.jar
hadoop-hdfs-0.21.0.jar
log4j-1.2.15.jar

動作環境
JDK6 Update22, Hadoop 0.21.0, H2 Database 1.2.147 (2010-11-21)

関連情報
CentOS5.5にHadoop0.21.0をインストールする
http://serverarekore.blogspot.com/2010/10/centos55hadoop0210.html

H2 DatabaseとHadoopでCLOBをHDFS上にアップロードする関数を作成する

2011-01-17T10:43:00.001+09:00

H2 DatabaseとHadoopでCLOBをHDFS上にアップロードする関数を作成するには、以下のコードを実行します。

create alias if not exists hdfs_put_ascii as $$ 
import java.io.*;
import java.util.*;
import java.sql.*;
import org.h2.tools.*;
import org.apache.hadoop.conf.*;
import org.apache.hadoop.fs.*;
import java.net.*;
@CODE
Integer hdfs_put_ascii(String uri, String user, 
  String path, Clob clob)
  throws Exception
{
  if( uri == null ){
    throw new Exception("uri is not specified.");
  }
  if( user == null ){
    throw new Exception("user is not specified.");
  }
  if( path == null ){
    throw new Exception("path is not specified.");
  }
  if( clob == null ){
    throw new Exception("clob is not specified.");
  }

  FileSystem fs = FileSystem.get(
    URI.create(uri), new Configuration(), user);

  FSDataOutputStream fos = null;
  InputStream ais = null;
  byte buf[] = new byte[8192];
  int rs = 0;
  try
  {
    ais = clob.getAsciiStream();
    fos = fs.create(new Path(path));
    while( (rs = ais.read(buf)) != -1 ){
      fos.write(buf, 0, rs);
    }
    fos.flush();
  }
  finally
  {
    if( ais != null )ais.close();
    if( fos != null )fos.close();
  }

  return new Integer(0);
}
$$

実行例

drop table if exists clobtest;
create table clobtest (c1 numeric(4), c2 clob);
insert into clobtest values (1, 
  hdfs_get_ascii(
  'hdfs://192.168.1.81:9000/',
  'hadoop', '/opt/hadoop-data/test.txt')
);
select hdfs_put_ascii(
  'hdfs://192.168.1.81:9000/',
  'hadoop', '/opt/hadoop-data/test2.txt', c2)
from clobtest 
where c1 = 1;

H2 DatabaseとHadoopでHDFS上のファイルをBLOBとして返す関数を作成する

2011-01-16T10:24:00.000+09:00

H2 DatabaseとHadoopでHDFS上のファイルをBLOBとして返す関数を作成するには、以下の手順を実行します。

1.以下のソースファイルをantなどでコンパイルします。
HdfsGetBinaryFunction.java

package com.serverarekore.h2;
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import org.apache.hadoop.conf.*;
import org.apache.hadoop.fs.*;
import java.net.*;

public class HdfsGetBinaryFunction
{
  static public InputStream hdfs_get_binary(String uri, 
    String user, String path)
    throws Exception
  {
    if( uri == null ){
      throw new Exception("uri is not specified.");
    }
    if( user == null ){
      throw new Exception("user is not specified.");
    }
    if( path == null ){
      throw new Exception("path is not specified.");
    }

    FileSystem fs = FileSystem.get(
      URI.create(uri), new Configuration(), user);
    InputStream ris = null;

    if( fs.exists(new Path(path)) == false ){
      return null;
    }
    InputStream is = fs.open(new Path(path));

    final File tf = File.createTempFile("lobtmp", null);
    FileOutputStream fos = new FileOutputStream(tf.getAbsolutePath());

    byte buf[] = new byte[8192];
    int rs = -1;
    try
    {
      while( (rs = is.read(buf)) != -1 ){
        fos.write(buf, 0, rs);
      }
    }
    finally
    {
      if( fos != null )fos.close();
      if( is != null )is.close();
    }

    ris = new InputStream(){
      private final InputStream fis = new FileInputStream(tf);
      private boolean deleted = false;
      private final File fn = tf;
      public int autoDelete(int sz) throws IOException
      {
        if(sz < 0 ){
          close();
        }
        return sz;
      }
      public void close() throws IOException
      {
        if( !deleted ){
          fis.close();
          fn.delete();
          deleted = true;
        }
      }
      public int read(byte buf[], int off, int len) throws IOException
      {
        return deleted?-1:autoDelete(fis.read(buf, off, len));
      }

      public int read(byte buf[]) throws IOException
      {
        return deleted?-1:autoDelete(fis.read(buf));
      }

      public int read() throws IOException 
      {
        return deleted?-1:autoDelete(fis.read());
      }
    };

    return ris;
  } 
}

build.xmlのサンプル

<project name="H2Functions" default="compile" basedir=".">
  <path id="lib.classpath">
    <fileset dir="lib">
      <include name="*.jar"/>
    </fileset>
    <pathelement location="c:/Program Files/H2/bin/h2-1.2.147.jar"/>
  </path>
  <target name="compile">
    <echo message="project: ${ant.project.name}"/>
    <mkdir dir="build/" />
    <javac srcdir="src/" destdir="build/" 
      deprecation="on" debug="on">
      <classpath>
        <path refid="lib.classpath"/>
      </classpath>
    </javac>
    <jar destfile="c:/share/jars/HdfsGetBinary.jar"
       basedir="build"/>
  </target>
  <target name="clean">
    <delete dir="build" />
  </target>
</project>

2.システム環境変数CLASSPATHにコンパイルしてできたHdfsGetBinary.jarを追加し、
H2 Databaseのサービスを再起動。

3.H2 Consoleから以下のコマンドを実行して、ファンクション作成。

create alias hdfs_get_binary for 
"com.serverarekore.h2.HdfsGetBinaryFunction.hdfs_get_binary";

4.以下のようなSQLでHDFS上のファイルをBLOBに格納できます。

drop table if exists blobtest;
create table blobtest (c1 numeric(4), c2 blob);
insert into blobtest values (1, 
  hdfs_get_binary(
  'hdfs://192.168.1.81:9000/',
  'user', '/opt/hadoop-data/SF.JPG')
);

serverあれこれ

H2 Database上でsardineでWebDAVサーバと連携するユーザ定義関数のまとめ

WebDAVサーバ上のリソース情報の取得

WebDAVサーバ上のリソースの操作

H2 Database上でOrion SSH2を使用するユーザー定義関数のまとめ

SSH2でコマンド実行

SFTPサーバ上のファイル・ディレクトリの情報取得

SFTPサーバ上のファイル・ディレクトリに対する操作

H2 Database上でSchemaCrawlerを使用するユーザー定義関数のまとめ

H2 Database上でTwitter4Jを使用するユーザー定義関数のまとめ

ツィート関連

ユーザ情報取得

フォロー/フォロワー関連

H2 DatabaseとSchemaCrawlerでテーブルのカラムを列挙する関数を作成する

H2 DatabaseとJRedisでキー値が存在しない場合のみ値を設定する関数を作成する

H2 DatabaseとSchemaCrawlerでテーブルを列挙する関数を作成する

H2 DatabaseとJRedisで新しい値を設定して古い値を返す関数を作成する

H2 DatabaseとJRedisでSorted Setの値のスコアを取得する関数を作成する

H2 DatabaseとJRedisでSorted Setから値を削除する関数を作成する

H2 DatabaseとJRedisでSorted Setからインデックスの範囲で逆順で値を取得する関数を作成する

H2 DatabaseとJRedisでスコアの範囲でSorted Setの値を取得する

H2 DatabaseとJRedisでSorted Setの要素数を取得する関数を作成する

H2 DatabaseとJRedisでSorted Setの値のスコアをインクリメントする関数を作成する

H2 DatabaseとJRedisでSorted Setからインデックスの範囲で値を取得する関数を作成する

H2 DatabaseとJRedisでSorted Setに値を追加する関数を作成する

H2 DatabaseとJRedisでセットから値を削除する関数を作成する

H2 DatabaseとSchemaCrawlerでスキーマを列挙する関数を作成する

H2 DatabaseとJRedisでサーバの情報を返す関数を作成する

H2 DatabaseとJRedisで複数のセットから差集合を作成する関数を作成する

H2 DatabaseとJRedisで複数のセットから和集合を作成する関数を作成する

H2 DatabaseとJRedisで複数のセットから積集合を作成する関数を作成する

H2 DatabaseとJRedisで複数のセットから差集合を返す関数を作成する

H2 DatabaseとJRedisで複数のセットから和集合を返す関数を作成する

H2 DatabaseとJRedisで複数のセットから積集合を返す関数を作成する

H2 DatabaseとJRedisでセットからランダムに値を返す関数を作成する

H2 DatabaseとJRedisでセットの値を別のセットに移動させる関数を作成する

H2 DatabaseとJRedisでセットに含まれる値を返す関数を作成する

H2 DatabaseでSchemaCrawlerの情報を取得する関数を作成する

H2 DatabaseとJRedisでセットに値が含まれるか確認する関数を作成する

H2 DatabaseとJRedisでセットに値を追加する関数を作成する

H2 DatabaseとJRedisでバックグラウンドでDBを保存する関数を作成する

H2 DatabaseとJRedisでソースリストから最後の要素を取得・削除して値を別のリストの最初に追加する関数を作成する

H2 DatabaseとJRedisでリストから指定のインデックスの要素を取得する関数を作成する

H2 DatabaseとJRedisでリストの最後の要素を取得して削除する関数を作成する

H2 DatabaseとJRedisでリストの最初の要素を取得して削除する関数を作成する

H2 DatabaseとJRedisでリストの指定した要素を削除する関数を作成する

H2 DatabaseとJRedisでリストの指定した範囲の要素のみを残す関数を作成する

H2 DatabaseとJRedisでリストのインデックスを指定して値を設定する関数を作成する

H2 DatabaseとSchemaCrawlerでデータベースのプロパティ情報を取得する関数を作成する

H2 DatabaseとJRedisでリストの要素数を返す関数を作成する

H2 DatabaseとJRedisでリストの最初に値を追加する関数を作成する

H2 DatabaseとJRedisでリストの指定した範囲の値を列挙する関数を作成する

H2 DatabaseとJRedisでリストの最後に値を追加する関数を作成する

H2 DatabaseとJRedisでキーを削除する関数を作成する

H2 DatabaseとJRedisで最後にディスクに保存した日付を取得する関数を作成する

H2 DatabaseとJRedisでkeyの数を取得する関数を作成する

H2 DatabaseとJRedisでkeyの値をデクリメントする関数を作成する

H2 DatabaseとTwitter4Jを使用してフォローしているユーザ名を取得する関数を作成する

H2 DatabaseとJRedisでkeyの値をインクリメントする関数を作成する

H2 DatabaseとSchemaCrawlerでデータベースの情報を取得する関数を作成する

H2 DatabaseとTwitter4Jを使用してフォロワーのユーザ名を取得する関数を作成する

H2 DatabaseとJRedisでkeyをリネームする関数を作成する

H2 DatabaseとTwitter4Jを使用して接続ユーザーのタイムラインを取得する関数を作成する

H2 DatabaseとOrion SSH2を使用してサーバ上でコマンドを実行する関数を作成する

H2 DatabaseとTwitter4Jを使用してフォローしている数を取得する関数を作成する

H2 DatabaseとJRedisで指定したkeyが存在するかどうかを返す関数を作成する

H2 DatabaseとOrion SSH2を使用してBLOBをSFTP上へアップロードする関数を作成する

H2 DatabaseとTwitter4Jを使用してフォロワー数を取得する関数を作成する

H2 DatabaseとOrion SSH2を使用してSFTPでファイルをダウンロードしてBLOBとして返す関数を作成する

H2 DatabaseとTwitter4Jを使用してお気に入りの数を取得する関数を作成する

H2 DatabaseとJRedisで指定したkeyのvalueを取得する関数を作成する

H2 DatabaseとOrion SSH2を使用してSFTPでファイルを移動・リネームする関数を作成する

H2 DatabaseとTwitter4Jを使用してツィート回数を取得する関数を作成する

H2 DatabaseとOrion SSH2を使用してSFTPでフルパスを取得する関数を作成する

H2 DatabaseとTwitter4Jを使用してユーザー名を取得する関数を作成する

H2 DatabaseとOrion SSH2を使用してSFTPでシンボリックリンクのターゲットを表示する関数を作成する

H2 DatabaseとJRedisでkey-valueを設定する関数を作成する

Apache Derbyで指定されたパスのファイルを列挙する関数を作成する

H2 DatabaseとOrion SSH2を使用してSFTPでディレクトリを削除する関数を作成する

Apache Derbyで指定されたファイルのサイズを返す関数を作成する