2011年2月28日月曜日

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

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

2011年2月27日日曜日

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

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

2011年2月26日土曜日

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

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

2011年2月25日金曜日

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

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

2011年2月24日木曜日

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

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

2011年2月23日水曜日

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

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

2011年2月22日火曜日

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

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上でTwitter4Jを使用するユーザー定義関数のまとめ

2011年2月21日月曜日

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

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

2011年2月20日日曜日

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

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');

※以下の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とTwitter4Jを使用してフォロワーのユーザ名を取得する関数を作成する

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を使用するユーザー定義関数のまとめ

2011年2月19日土曜日

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

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

2011年2月18日金曜日

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

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);

※以下の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を使用するユーザー定義関数のまとめ

2011年2月17日木曜日

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

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を使用するユーザー定義関数のまとめ

2011年2月16日水曜日

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

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');

※以下の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が存在するかどうかを返す関数を作成する

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

2011年2月15日火曜日

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

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;


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

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

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

2011年2月14日月曜日

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

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');

※以下の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を使用するユーザー定義関数のまとめ

2011年2月13日日曜日

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

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')
);


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

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

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

2011年2月12日土曜日

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

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');

※以下の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を使用するユーザー定義関数のまとめ

2011年2月11日金曜日

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

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でファイルを移動・リネームする関数を作成する

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')


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

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

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

2011年2月10日木曜日

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

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');

※以下の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を使用するユーザー定義関数のまとめ

2011年2月9日水曜日

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

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')


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

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

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

2011年2月8日火曜日

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

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');

※以下の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を使用するユーザー定義関数のまとめ

2011年2月7日月曜日

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

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')


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

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

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

2011年2月6日日曜日

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

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で指定されたパスのファイルを列挙する関数を作成する

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

2011年2月5日土曜日

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

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')


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

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

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

2011年2月4日金曜日

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

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

2011年2月3日木曜日

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

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)


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

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

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

2011年2月2日水曜日

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

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;