2010年10月31日日曜日

H2 DatabaseとJCIFSでBLOBをファイルとしてWindows共有上にアップロードする関数を作成する

H2 DatabaseとJCIFSでBLOBをファイルとしてWindows共有上にアップロードする関数を作成するには、以下のスクリプトを実行します。

drop alias jcifs_put_binary;
create alias if not exists jcifs_put_binary as $$
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import jcifs.smb.*;
@CODE
int jcifs_put_binary(String domain,
String user, String password, String server,
String path, String filename, Blob blob)
throws Exception
{
if( domain == null ){
throw new Exception("domain is not specified.");
}
user = (user == null)?"":user;
password = (password == null)?"":password;
if( server == null ){
throw new Exception("server is not specified.");
}
if( path == null ){
throw new Exception("path is not specified.");
}
if( filename == null ){
throw new Exception("filename is not specified.");
}


OutputStream os = null;
InputStream bis = null;
try
{
os = new SmbFileOutputStream(
"smb://" + domain + ";" + user + ":" + password +
"@" + server + "/" + path + "/" + filename);
bis = blob.getBinaryStream();

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

return 0;
}
$$


実行例
drop table if exists blobtest;
create table blobtest (c1 numeric(4), c2 blob);
insert into blobtest values (1,
jcifs_get_binary('LIFERAY1',
'test1', 'test1', 'liferay1',
'share', 'SF.JPG')
);
select jcifs_put_binary('LIFERAY1',
'test1', 'test1', 'liferay1',
'share/h2', 'renamed_SF.JPG', c2)
from blobtest
where c1 = 1;


※システム環境変数CLASSPATHにtools.jarとJCIFSのjar
(jcifs-1.3.15.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), JCIFS 1.3.15

2010年10月30日土曜日

CentOS5.5にHadoop0.21.0をインストールする

CentOS5.5にHadoop0.21.0をインストールするには、以下の手順を実行します。

○Sun JDKのdownload&install
以下のサイトからrpm版を落として、インストール
http://java.sun.com/javase/ja/6/download.html

chmod +x jdk-6u22-linux-x64-rpm.bin
./jdk-6u22-linux-x64-rpm.bin

インストールしたJDKをalternativesのリストに追加
alternatives --install /usr/bin/java java /usr/java/jdk1.6.0_22/bin/java 200
alternatives --config javaで、インストールしたJDKを選択

vi /etc/profile
以下を最終行に追加
export JAVA_HOME=/usr/java/jdk1.6.0_22
保存して
source /etc/profile

○hadoop用のユーザ追加
groupadd -g 2000 hadoop
useradd -g hadoop -u 2000 hadoop
passwd hadoop
パスワードを2回入力

○hadoopのインストール
tar xvfz hadoop-0.21.0.tar.gz
mv hadoop-0.21.0 /opt/hadoop-0.21.0
cd /opt
chown -R hadoop:hadoop hadoop-0.21.0

vi /etc/profile
以下を最終行に追加
export HADOOP_HOME=/opt/hadoop-0.21.0
export PATH=$PATH:$HADOOP_HOME/bin
保存して
source /etc/profile

○ssh設定
su - hadoop
ssh-keygen -t dsa -P '' -f ~/.ssh/id_dsa
cat ~/.ssh/id_dsa.pub >> ~/.ssh/authorized_keys
chmod 600 ~/.ssh/authorized_keys
ssh hadoop0
以下のメッセージが出たらyesを入力
Are you sure you want to continue connecting (yes/no)? yes
exit

○hadoop設定

cd $HADOOP_HOME/conf
vi hadoop-env.sh
以下の行を追加
export JAVA_HOME=/usr/java/jdk1.6.0_22

vi $HADOOP_HOME/conf/core-site.xml
configuration要素を以下のように設定
<configuration>
<property>
<name>fs.default.name</name>
<value>hdfs://hadoop0:9000</value>
</property>
</configuration>

vi $HADOOP_HOME/conf/hdfs-site.xml
configuration要素を以下のように設定
<configuration>
<property>
<name>dfs.replication</name>
<value>1</value>
</property>
</configuration>

vi $HADOOP_HOME/conf/mapred-site.xml
configuration要素を以下のように設定
<configuration>
<property>
<name>mapred.job.tracker</name>
<value>hadoop0:9001</value>
</property>
</configuration>

vi $HADOOP_HOME/conf/masters
localhostを消してホスト名入力

vi $HADOOP_HOME/conf/slaves
localhostを消してホスト名入力

hdfs namenode -format
start-dfs.sh
start-mapred.sh

動作環境
CentOS5.5, hadoop 0.21.0, JDK6 Update22

H2 DatabaseとJCIFSでCLOBをファイルとしてWindows共有上にアップロードする関数を作成する

H2 DatabaseとJCIFSでCLOBをファイルとしてWindows共有上にアップロードする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jcifs_put_ascii as $$ 
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import jcifs.smb.*;
@CODE
int jcifs_put_ascii(String domain,
String user, String password, String server,
String path, String filename, Clob clob)
throws Exception
{
if( domain == null ){
throw new Exception("domain is not specified.");
}
user = (user == null)?"":user;
password = (password == null)?"":password;
if( server == null ){
throw new Exception("server is not specified.");
}
if( path == null ){
throw new Exception("path is not specified.");
}
if( filename == null ){
throw new Exception("filename is not specified.");
}


OutputStream os = null;
InputStream ais = null;
try
{
os = new SmbFileOutputStream(
"smb://" + domain + ";" + user + ":" + password +
"@" + server + "/" + path + "/" + filename);
ais = clob.getAsciiStream();

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

return 0;
}
$$


実行例
drop table if exists clobtest;
create table clobtest (c1 numeric(4), c2 clob);
insert into clobtest values (1,
jcifs_get_ascii('LIFERAY1',
'test1', 'test1', 'liferay1',
'share/h2', 'titles.txt')
);
select jcifs_put_ascii('LIFERAY1',
'test1', 'test1', 'liferay1',
'share/h2', 'renamed_titles.txt', c2)
from clobtest
where c1 = 1;


※システム環境変数CLASSPATHにtools.jarとJCIFSのjar
(jcifs-1.3.15.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), JCIFS 1.3.15

2010年10月29日金曜日

H2 DatabaseとJCIFSでWindows共有上のファイルをBLOBで返す関数を作成する

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

1.以下のソースファイルをantなどでコンパイルします。
JCIFSGetBinaryFunction.java
package com.serverarekore.h2;
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import jcifs.smb.*;

public class JCIFSGetBinaryFunction
{
static public InputStream jcifs_get_binary(String domain,
String user, String password, String server,
String path, String filename)
throws Exception
{
if( domain == null ){
throw new Exception("domain is not specified.");
}
user = (user == null)?"":user;
password = (password == null)?"":password;
if( server == null ){
throw new Exception("server is not specified.");
}
if( path == null ){
throw new Exception("path is not specified.");
}
if( filename == null ){
throw new Exception("filename is not specified.");
}

InputStream ris = null;

InputStream is = new SmbFileInputStream(
"smb://" + domain + ";" + user + ":" + password +
"@" + server + "/" + path + "/" + filename);

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.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/JCIFSGetBinary.jar"
basedir="build"/>
</target>
<target name="clean">
<delete dir="build" />
</target>
</project>


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

3.H2 Consoleから以下のコマンドを実行して、ファンクション作成。
create alias jcifs_get_binary for 
"com.serverarekore.h2.JCIFSGetBinaryFunction.jcifs_get_binary";


4.以下のようなコマンドでWindows共有上のファイルをBLOBに格納できます。
drop table if exists blobtest;
create table blobtest (c1 numeric(4), c2 blob);
insert into blobtest values (1,
jcifs_get_binary('LIFERAY1',
'test1', 'test1', 'liferay1',
'share', 'SF.JPG')
);


※システム環境変数CLASSPATHにtools.jarとJCIFSのjar
(jcifs-1.3.15.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), JCIFS 1.3.15

2010年10月28日木曜日

H2 DatabaseとJCIFSでWindows共有上のファイルをCLOBで返す関数を作成する

H2 DatabaseとJCIFSでWindows共有上のファイルをCLOBで返す関数を作成するには、以下の手順を実行します。

1.以下のソースファイルをantなどでコンパイルします。
JCIFSGetAsciiFunction.java
package com.serverarekore.h2;
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import jcifs.smb.*;

public class JCIFSGetAsciiFunction
{
static public Reader jcifs_get_ascii(String domain,
String user, String password, String server,
String path, String filename)
throws Exception
{
if( domain == null ){
throw new Exception("domain is not specified.");
}
user = (user == null)?"":user;
password = (password == null)?"":password;
if( server == null ){
throw new Exception("server is not specified.");
}
if( path == null ){
throw new Exception("path is not specified.");
}
if( filename == null ){
throw new Exception("filename is not specified.");
}

Reader reader = null;

InputStreamReader isr = new InputStreamReader(
new SmbFileInputStream(
"smb://" + domain + ";" + user + ":" + password +
"@" + server + "/" + path + "/" + filename)
);

final File tf = File.createTempFile("lobtmp", null);
FileWriter fw = new FileWriter(tf.getAbsolutePath());

char buf[] = new char[8192];
int rs = -1;
try
{
while( (rs = isr.read(buf)) != -1 ){
fw.write(buf, 0, rs);
}
}
finally
{
fw.close();
isr.close();
}

reader = new Reader(){
private final Reader reader = new FileReader(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 ){
reader.close();
fn.delete();
deleted = true;
}
}
public int read(char buf[], int off, int len) throws IOException
{
return deleted?-1:autoDelete(reader.read(buf, off, len));
}

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

public int read() throws IOException
{
return deleted?-1:autoDelete(reader.read());
}
public int read(java.nio.CharBuffer target) throws IOException
{
return deleted?-1:autoDelete(reader.read(target));
}
};

return reader;
}
}


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.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/JCIFSGetAscii.jar"
basedir="build"/>
</target>
<target name="clean">
<delete dir="build" />
</target>
</project>


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

3.H2 Consoleから以下のコマンドを実行して、ファンクション作成。
create alias jcifs_get_ascii for 
"com.serverarekore.h2.JCIFSGetAsciiFunction.jcifs_get_ascii";


4.以下のようなコマンドでWindows共有上のファイルをCLOBに格納できます。
drop table if exists clobtest;
create table clobtest (c1 numeric(4), c2 clob);
insert into clobtest values (1,
jcifs_get_ascii('LIFERAY1',
'test1', 'test1', 'liferay1',
'share/h2', 'titles.txt')
);
select * from clobtest;


※システム環境変数CLASSPATHにtools.jarとJCIFSのjar
(jcifs-1.3.15.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), JCIFS 1.3.15

2010年10月27日水曜日

H2 DatabaseとJCIFSでWindows共有上のファイルを列挙する関数を作成する

H2 DatabaseとJCIFSでWindows共有上のファイルを列挙する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists jcifs_list_files as $$ 
import java.io.*;
import java.sql.*;
import java.util.*;
import jcifs.smb.*;
import org.h2.tools.*;
@CODE
ResultSet jcifs_list_files(String domain,
String user, String password, String server,
String path)
throws Exception
{
if( domain == null ){
throw new Exception("domain is not specified.");
}
user = (user == null)?"":user;
password = (password == null)?"":password;
if( server == null ){
throw new Exception("server is not specified.");
}
if( path == null ){
throw new Exception("path is not specified.");
}

SimpleResultSet rs = new SimpleResultSet();
rs.addColumn("NAME", Types.VARCHAR, 512, 0);

SmbFile sfile = new SmbFile(
"smb://" + domain + ";" + user + ":" + password +
"@" + server + "/" + path + "/");
//Windows共有上の ファイルの列挙
SmbFile files[] = sfile.listFiles();
for(int fi=0;fi<files.length;fi++){
rs.addRow(files[fi].getName());
}
return rs;
}
$$


実行例
call jcifs_list_files('LIFERAY1', 
'test1', 'test1', 'liferay1', 'share/jars');


※システム環境変数CLASSPATHにtools.jarとJCIFSのjar
(jcifs-1.3.15.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), JCIFS 1.3.15

2010年10月26日火曜日

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルの所有者のグループ(グループID)を返す関数を作成する

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルの所有者のグループ(グループID)を返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists ftp_get_group as $$ 
import java.io.*;
import java.sql.*;
import java.util.*;
import org.apache.commons.net.ftp.*;
@CODE
String ftp_get_group(String host, Integer port,
String user, String password, String encoding,
String path, String filename)
throws Exception
{
String result = null;
if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
encoding = (encoding == null)?"UTF-8":encoding;
path = (path == null)?".":path;
if( filename == null ){
throw new Exception("filename is not specified.");
}

FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}
// エンコーディングの設定
fc.setControlEncoding(encoding);

// グループ(グループID)の取得
FTPFile files[] = fc.listFiles(filename);
if( files.length > 1 ){
throw new Exception("too many files!");
}
result = files[0].getGroup();
// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

return result;
}
$$


実行例
call ftp_get_group('192.168.1.122', 21, 
'ftptest1', 'ftptest1',
'UTF-8', '.', 'SF.JPG');


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0

2010年10月25日月曜日

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルの所有者のユーザ(ユーザID)を返す関数を作成する

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルの所有者のユーザ(ユーザID)を返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists ftp_get_user as $$ 
import java.io.*;
import java.sql.*;
import java.util.*;
import org.apache.commons.net.ftp.*;
@CODE
String ftp_get_user(String host, Integer port,
String user, String password, String encoding,
String path, String filename)
throws Exception
{
String result = null;
if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
encoding = (encoding == null)?"UTF-8":encoding;
path = (path == null)?".":path;
if( filename == null ){
throw new Exception("filename is not specified.");
}

FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}
// エンコーディングの設定
fc.setControlEncoding(encoding);

// ユーザ(ユーザID)の取得
FTPFile files[] = fc.listFiles(filename);
if( files.length > 1 ){
throw new Exception("too many files!");
}
result = files[0].getUser();
// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

return result;
}
$$


実行例
call ftp_get_user('192.168.1.122', 21, 
'ftptest1', 'ftptest1',
'UTF-8', '.', 'SF.JPG');


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0

2010年10月24日日曜日

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルのタイムスタンプを返す関数を作成する

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルのタイムスタンプを返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists ftp_get_timestamp as $$ 
import java.io.*;
import java.sql.*;
import java.util.*;
import org.apache.commons.net.ftp.*;
@CODE
Timestamp ftp_get_timestamp(String host, Integer port,
String user, String password, String encoding,
String path, String filename)
throws Exception
{
Timestamp result = null;
if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
encoding = (encoding == null)?"UTF-8":encoding;
path = (path == null)?".":path;
if( filename == null ){
throw new Exception("filename is not specified.");
}

FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}
// エンコーディングの設定
fc.setControlEncoding(encoding);

// タイムスタンプの取得
FTPFile files[] = fc.listFiles(filename);
if( files.length > 1 ){
throw new Exception("too many files!");
}
result = new Timestamp(
files[0].getTimestamp().getTime().getTime() +
TimeZone.getDefault().getOffset(new java.util.Date().getTime()));
// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

return result;
}
$$


実行例
call ftp_get_timestamp('192.168.1.122', 21, 
'ftptest1', 'ftptest1',
'UTF-8', '.', 'SF.JPG');


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0

2010年10月23日土曜日

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルのサイズを返す関数を作成する

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルのサイズを返す関数を作成するには、以下のスクリプトを実行します。

create alias if not exists ftp_get_filesize as $$ 
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import org.h2.value.*;
import org.apache.commons.net.ftp.*;
@CODE
long ftp_get_filesize(String host, Integer port,
String user, String password, String encoding,
String path, String filename)
throws Exception
{
long result = -1;
if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
encoding = (encoding == null)?"UTF-8":encoding;
path = (path == null)?".":path;
if( filename == null ){
throw new Exception("filename is not specified.");
}

FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}
// エンコーディングの設定
fc.setControlEncoding(encoding);

// ファイルサイズの取得
FTPFile files[] = fc.listFiles(filename);
if( files.length > 1 ){
throw new Exception("too many files!");
}
result = files[0].getSize();
// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

return result;
}
$$


実行例
call ftp_get_filesize('192.168.1.122', 21, 
'ftptest1', 'ftptest1',
'UTF-8', '.', 'SF.JPG');


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0

2010年10月22日金曜日

H2 DatabaseとApache Commons NetでFTPサーバ上のディレクトリを削除する関数を作成する

H2 DatabaseとApache Commons NetでFTPサーバ上のディレクトリを削除する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists ftp_delete_dir as $$ 
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import org.h2.value.*;
import org.apache.commons.net.ftp.*;
@CODE
int ftp_delete_dir(String host, Integer port,
String user, String password, String encoding,
String path, String dir)
throws Exception
{

if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
encoding = (encoding == null)?"UTF-8":encoding;
path = (path == null)?".":path;
if( dir == null ){
throw new Exception("directory is not specified.");
}

Reader reader = null;
FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}
// エンコーディングの設定
fc.setControlEncoding(encoding);

// ディレクトリの削除
if( !fc.removeDirectory(path + '/' + dir) ){
throw new Exception("failed to delete a directory.");
}

// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

return 0;
}
$$


実行例
call ftp_delete_dir('192.168.1.122', 21, 
'ftptest1', 'ftptest1',
'UTF-8', '.', 'example');


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0

2010年10月21日木曜日

H2 DatabaseとApache Commons NetでFTPサーバ上にディレクトリを作成する関数を作成する

H2 DatabaseとApache Commons NetでFTPサーバ上にディレクトリを作成する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists ftp_create_dir as $$ 
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import org.h2.value.*;
import org.apache.commons.net.ftp.*;
@CODE
int ftp_create_dir(String host, Integer port,
String user, String password, String encoding,
String path, String dir)
throws Exception
{

if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
encoding = (encoding == null)?"UTF-8":encoding;
path = (path == null)?".":path;
if( dir == null ){
throw new Exception("directory is not specified.");
}

Reader reader = null;
FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}
// エンコーディングの設定
fc.setControlEncoding(encoding);

// ディレクトリを作成
if( !fc.makeDirectory(path + '/' + dir) ){
throw new Exception("failed to create a directory.");
}

// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

return 0;
}
$$


実行例
call ftp_create_dir('192.168.1.122', 21, 
'ftptest1', 'ftptest1',
'UTF-8', '.', 'example');


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0

2010年10月20日水曜日

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルをリネームする関数を作成する

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルをリネームする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists ftp_rename_file as $$ 
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import org.h2.value.*;
import org.apache.commons.net.ftp.*;
@CODE
int ftp_rename_file(String host, Integer port,
String user, String password, String encoding,
String path, String filename, String renamedFile)
throws Exception
{

if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
encoding = (encoding == null)?"UTF-8":encoding;
path = (path == null)?".":path;
if( filename == null ){
throw new Exception("filename is not specified.");
}

Reader reader = null;
FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}
// エンコーディングの設定
fc.setControlEncoding(encoding);

// ファイルのリネーム
if( !fc.rename(path + '/' + filename,
path + '/' + renamedFile) ){
throw new Exception("failed to rename a file.");
}

// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

return 0;
}
$$


実行例
call ftp_rename_file('192.168.1.122', 21, 
'ftptest1', 'ftptest1',
'UTF-8', '.',
'uploaded_SF.JPG', 'renamed_SF.JPG');


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0

2010年10月19日火曜日

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルを削除する関数を作成する

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルを削除する関数を作成するには、以下のスクリプトを実行します。

create alias if not exists ftp_delete_file as $$ 
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import org.h2.value.*;
import org.apache.commons.net.ftp.*;
@CODE
int ftp_delete_file(String host, Integer port,
String user, String password, String encoding,
String path, String filename)
throws Exception
{

if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
encoding = (encoding == null)?"UTF-8":encoding;
path = (path == null)?".":path;
if( filename == null ){
throw new Exception("filename is not specified.");
}

Reader reader = null;
FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}
// エンコーディングの設定
fc.setControlEncoding(encoding);

// ファイルの削除
if( !fc.deleteFile(path + '/' + filename) ){
throw new Exception("failed to delete a file.");
}

// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

return 0;
}
$$


実行例
call ftp_delete_file('192.168.1.122', 21, 
'ftptest1', 'ftptest1',
'UTF-8', '.', 'uploaded_readme.txt');


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0

2010年10月18日月曜日

H2 DatabaseとApache Commons NetでBLOBをファイルとしてFTPサーバにアップロードする関数を作成する

H2 DatabaseとApache Commons NetでBLOBをファイルとしてFTPサーバにアップロードする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists ftp_put_binary as $$ 
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import org.h2.value.*;
import org.apache.commons.net.ftp.*;
@CODE
int ftp_put_binary(String host, Integer port,
String user, String password, String encoding,
String path, String filename, Blob blob)
throws Exception
{

if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
encoding = (encoding == null)?"UTF-8":encoding;
path = (path == null)?".":path;
if( filename == null ){
throw new Exception("filename is not specified.");
}

Reader reader = null;
FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}
// エンコーディングの設定
fc.setControlEncoding(encoding);

// ファイル転送モードをbinaryに
fc.setFileType(FTP.BINARY_FILE_TYPE);

// ファイルのアップロード
InputStream bis = null;
try
{
bis = blob.getBinaryStream();
if( !fc.storeFile(path + '/' + filename, bis) ){
throw new Exception("failed to upload a file.");
}
}
finally
{
if( bis != null )bis.close();
}

// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

return 0;
}
$$


実行例
drop table if exists blobtest;
create table blobtest (c1 numeric(4), c2 blob);
insert into blobtest values (1,
ftp_get_binary('192.168.1.122', 21,
'ftptest1', 'ftptest1',
'.', 'SF.JPG')
);

select ftp_put_binary('192.168.1.122', 21,
'ftptest1', 'ftptest1',
'UTF-8', '.', 'uploaded_SF.JPG', c2)
from blobtest
where c1 = 1;


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0

2010年10月17日日曜日

H2 DatabaseとApache Commons NetでCLOBをファイルとしてFTPサーバにアップロードする関数を作成する

H2 DatabaseとApache Commons NetでCLOBをファイルとしてFTPサーバにアップロードする関数を作成するには、以下のスクリプトを実行します。

create alias if not exists ftp_put_ascii as $$ 
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import org.h2.value.*;
import org.apache.commons.net.ftp.*;
@CODE
int ftp_put_ascii(String host, Integer port,
String user, String password, String encoding,
String path, String filename, Clob clob)
throws Exception
{

if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
encoding = (encoding == null)?"UTF-8":encoding;
path = (path == null)?".":path;
if( filename == null ){
throw new Exception("filename is not specified.");
}

Reader reader = null;
FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}
// エンコーディングの設定
fc.setControlEncoding(encoding);

// ファイル転送モードをasciiに
fc.setFileType(FTP.ASCII_FILE_TYPE);

// ファイルのアップロード
InputStream ais = null;
try
{
ais = clob.getAsciiStream();
if( !fc.storeFile(path + '/' + filename, ais) ){
throw new Exception("failed to upload a file.");
}
}
finally
{
if( ais != null )ais.close();
}

// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

return 0;
}
$$


実行例
drop table if exists clobtest;
create table clobtest (c1 numeric(4), c2 clob);
insert into clobtest values (1,
ftp_get_ascii('192.168.1.122', 21,
'ftptest1', 'ftptest1',
'UTF-8', '.', 'readme.txt')
);
select ftp_put_ascii('192.168.1.122', 21,
'ftptest1', 'ftptest1',
'UTF-8', '.', 'uploaded_readme.txt', c2)
from clobtest
where c1 = 1;


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0

2010年10月16日土曜日

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルをBLOBで返す関数を作成する

H2 DatabaseとApache Commons NetでFTPサーバ上のファイルをBLOBで返す関数を作成するには、以下の手順を実行します。

1.以下のソースファイルをantなどでコンパイルします。
GetFtpBinaryFunction.java
package com.serverarekore.h2;
import java.io.*;
import java.sql.*;
import org.h2.tools.*;
import org.h2.value.*;
import org.apache.commons.net.ftp.*;

public class FtpGetBinaryFunction
{
static public InputStream ftp_get_binary(String host, Integer port,
String user, String password,
String path, String filename)
throws Exception
{

if( host == null ){
throw new Exception("host is not specified.");
}
int intPort = (port == null)?21:port.intValue();
user = (user == null)?"":user;
password = (password == null)?"":password;
path = (path == null)?".":path;
if( filename == null ){
throw new Exception("filename is not specified.");
}

InputStream ris = null;
FTPClient fc = new FTPClient();
try
{
// 接続
fc.connect(host, intPort);
if( !FTPReply.isPositiveCompletion(fc.getReplyCode()) ){
throw new Exception("failed to connect.");
}
// ログイン
if( fc.login(user, password) == false ){
throw new Exception("failed to login.");
}

// ファイル転送モードをasciiに
fc.setFileType(FTP.ASCII_FILE_TYPE);

// ファイルのダウンロード
InputStream is = fc.retrieveFileStream(filename);

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
{
fos.close();
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());
}
};

// ログアウト
fc.logout();
}
finally
{
if( fc.isConnected() ){
fc.disconnect();
}
}

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.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/FtpGetBinary.jar"
basedir="build"/>
</target>
<target name="clean">
<delete dir="build" />
</target>
</project>


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

3.H2 Consoleから以下のコマンドを実行して、ファンクション作成。
create alias ftp_get_binary for 
"com.serverarekore.h2.FtpGetBinaryFunction.ftp_get_binary";


4.以下のようなコマンドでFTPサーバ上のファイルをBLOBに格納できます。
drop table if exists blobtest;
create table blobtest (c1 numeric(4), c2 blob);
insert into blobtest values (1,
ftp_get_binary('192.168.1.122', 21,
'ftptest1', 'ftptest1',
'.', 'SF.JPG')
);


※システム環境変数CLASSPATHにtools.jarとApache Commons Netのjar
(commons-net-2.0.jar, commons-net-ftp-2.0.jar)を追加しておくこと。

動作環境
JDK6 Update 21, H2 Database 1.2.143 (2010-09-18), Apache Commons Net 2.0