Home > Tags > Java

Java

WTPのTomcat7.0でDataSource(PostgreSQL)からConnectionを取得する

コネクションプーリングをするために、DataSourceからコネクションを取得しようと思ったら、かなりハマってしまったので、備忘録です。

手順は以下。PostgreSQLの例ですが、大体どのDB製品でも同じだと思います。

  1. (サーバの)server.xmlにResourceを定義
  2. (アプリケーションの)web.xmlにresource-refを定義
  3. JDBCドライバを配備
  4. コネクション取得

(サーバの)server.xmlにResourceを定義

まずserver.xmlにResourceを定義します。WTPでサーバを動かしている場合は、以下のようにServersプロジェクト内にserver.xmlがあると思います。

server.xml
server.xml

この中にアプリケーションのContextタグがあると思うので、そこにResourceを追加する。
ここが、Tomcat 6.0と記述が異なっていたので、かなりハマってしまいました。しっかりマニュアルのほうを読まないといけませんね。

server.xml

<Context docBase="Sample" path="/Sample" reloadable="true" source="org.eclipse.jst.jee.server:Sample">
	<Resource name="jdbc/postgresql" auth="Container" type="javax.sql.DataSource"
		driverClassName="org.postgresql.Driver" url="jdbc:postgresql://localhost/SampleDB" username="postgres"
		password="xxxxxx" maxActive="20" maxIdle="10" maxWait="-1" />
</Context>

(アプリケーションの)web.xmlにresource-refを定義

次にアプリケーション内のweb.xmlにresource-refを定義します。サーバのweb.xmlではないので注意。

web.xml

<resource-ref>
	<res-ref-name>jdbc/postgresql</res-ref-name>
	<res-type>javax.sql.DataSource</res-type>
	<res-auth>Container</res-auth>
</resource-ref>

JDBCドライバを配備

WTPでサーバを起動している場合は、サーバプログラム本体のcommon/libにいくらjarを置いてもクラスパスには追加されません。
WTPでjarを追加するには以下のようにします。

プロジェクト・エクスプローラーを右クリック → 実行(実行構成) → クラスパス → ユーザー・エントリでjarを追加

コネクション取得

これで準備ができたので、実際にServletからコネクションを取得してみます。

SampleServlet

package jp.co.njk.nems.controller.authentication;

import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;

import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;

@WebServlet("/SampleServlet")
public class SampleServlet extends HttpServlet {

    private static final long serialVersionUID = 1L;

    private Connection connection;

    public void init(ServletConfig config) throws ServletException {
        try {
            InitialContext context = new InitialContext();
            DataSource dataSource = (DataSource) context.lookup("java:comp/env/jdbc/postgresql");
            connection = dataSource.getConnection();

        } catch (NamingException e) {
            throw new RuntimeException(e);
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }

    protected void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        System.out.println(connection);
    }
}

参考

livedoor Reader をJavaから操作する何か作った

  • Posted by: sinsengumi
  • 2011年2月21日 12:21 AM
  • Java
  • |

追記
Github にホスティングしました。これからはGithub 使います。
https://github.com/sinsengumi/LDR4J

掲題の通り、livedoor Reader をJavaからHTTPアクセスして未読記事取ったり、ピン付けたりするライブラリ「ldr4j」を作りました。
実はAndroidでlivedoor Readerクライアントアプリを作りたくて、その前段階としてこのラッパーライブラリを作った感じです。

で、生まれてはじめて、まとまったコードをOSSとして公開してみました。
コードはSourceForge.JPでホスティングしています。
(eclipseプラグインのEGITがよさそうであれば、githubでホスティングしたいと思います。)

「ldr4j」プロジェクトページ

http://sourceforge.jp/projects/ldr4j/

以下で、Subversionからチェックアウトできます。
http://svn.sourceforge.jp/svnroot/ldr4j/

※なお、livedoor Reader API はlivedoor から正式にアナウンスされているAPIではないので、仕様変更で使えなくなる可能性はあります。

livedoor Reader が大好きで、もうこれがないとネット生活していけないくらいですね。
今回 ldr4j を作っていく過程で、livedoor Reader がどういう風に出来ているかもなんとなくですがわかりました(livedoor ReaderのOSS版である fastladder を参考にしました。)

このライブラリはこれからもちゃんとメンテナンスしていこー。テストとかもちゃんと書きたいし。

参考

よく見るClosable使ったコード

  • Posted by: sinsengumi
  • 2011年2月16日 8:23 PM
  • Java

Streamなんかを閉じる(close)時のコードなんかでよく見るパターン。
nullチェックして、closeする。さらにそのcloseはチェック例外出すからめんどいよ、ってことなのかしら。
結構有名なのかな?

private void close(Closeable stream) {
    if (stream != null) {
        try {
            stream.close();
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }
}

JavaでFTPアップロードを行う。

  • Posted by: sinsengumi
  • 2011年2月1日 9:00 PM
  • Java
  • |

JavaでFTPを使用するにはいくらか方法がありますが、仕事でcommons-netのFTPを使ったのでその備忘録です。

実行環境は以下です。

  • JRE 1.6
  • commons-net-2.0.jar

はまった箇所が2点ほどあって、ひとつはエンコーディングの設定は必ずコネクトする前に行うこと。とPASVモードについてです。

commons-netのFTPClientクラスで、PASVモードにできそうな名前のメソッドが2つあって、それのどっちを使えばいいのか、もしくは違うのか結構悩みました。

  • enterLocalPassiveMode()
  • enterRemotePassiveMode()

結果的にいうと、どっちも違くて、FTPClientの親クラスであるFTPクラスのpasv()メソッドでOKでした。
これらの違いは、ソースやJavadocを見た感じ、恐らく以下のような感じだと思います。

pasv()

FTPのPASVコマンドを発行する。

enterLocalPassiveMode()

dataConnectionModeを「2」に設定する。

enterRemotePassiveMode()

内部的にpasv()を呼び出している。

以下、サンプルコードです。

public class FTPUpload {

    private static final String FTP_HOST = "127.0.0.1";
    private static final String FTP_USER = "username";
    private static final String FTP_PASSWORD = "password";

    private static final String UPLOAD_FILE = "C:\\サンプル.xls";
    private static final String UPLOADED_FILENAME = "リネーム.xls";

    public static void main(String[] args) {
        try {
            execute();
        } catch (ApplicationException e) {
            e.printStackTrace();
        }
    }

    private static void execute() throws ApplicationException {

        FTPClient ftpClient = new FTPClient();

        try {
            // エンコーディングの設定は、connectする前に行う。
            ftpClient.setControlEncoding("SJIS");

            // FTPサーバに接続
            ftpClient.connect(FTP_HOST);
            printFtpReply(ftpClient);

            // ログイン
            ftpClient.login(FTP_USER, FTP_PASSWORD);
            printFtpReply(ftpClient);

            // PASVモードに設定
            ftpClient.pasv();
            printFtpReply(ftpClient);

            // データの変換モードをバイナリに設定
            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
            printFtpReply(ftpClient);

            // ファイル転送
            FileInputStream fis = new FileInputStream(UPLOAD_FILE);
            ftpClient.storeFile(UPLOADED_FILENAME, fis);
            printFtpReply(ftpClient);

        } catch (NumberFormatException e) {
            throw new ApplicationException("FTPポートの値が数値ではありません。", e);
        } catch (SocketException e) {
            throw new ApplicationException("Socket通信に失敗しました。", e);
        } catch (FileNotFoundException e) {
            throw new ApplicationException("アップロードするファイルが見つかりません。", e);
        } catch (IOException e) {
            throw new ApplicationException("IOレベルで例外が発生しました。", e);
        } finally {
            if (ftpClient.isConnected()) {
                try {
                    ftpClient.disconnect();
                } catch (IOException e) {
                    // ignore
                }
            }
        }
    }

    private static void printFtpReply(FTPClient ftpClient)throws ApplicationException {

        System.out.print(ftpClient.getReplyString());

        int replyCode = ftpClient.getReplyCode();

        if (!FTPReply.isPositiveCompletion(replyCode)) {
            throw new ApplicationException("送信したFTPコマンドは失敗しました。");
        }
    }
}

PASVモードやFTPのプロトコルに関しては、以下が大変参考になりました。
http://www.atmarkit.co.jp/fnetwork/rensai/netpro10/netpro01.html

JavaでMapコレクションの繰り返し

  • Posted by: sinsengumi
  • 2010年10月22日 11:34 AM
  • Java

毎回忘れて、調べてるのでメモ。

public class Sample {

    public static void main(String[] args) {

        Map<Integer, String> map = new HashMap<Integer, String>();
        map.put(0, "Kondou");
        map.put(1, "Hijikata");

        for (Entry<Integer, String> e : map.entrySet()) {
            System.out.print(e.getKey());
            System.out.print(" ");
            System.out.println(e.getValue());
        }
    }
}

JavaのHttpClient 4 を触ってみた。

  • Posted by: sinsengumi
  • 2010年10月7日 11:30 AM
  • Java
  • |

HttpClientの3.0系はレガシーということで、4系を触ってみました。
実行環境は以下です。

  • JRE 1.6
  • HttpClient 4.0.3 (httpclient-4.0.3.jar)
  • HttpCore 4.0.1 (httpcore-4.0.1.jar)
  • Commons Logging 1.1.1 (commons-logging-1.1.1.jar)

簡単に、HTTP接続ができていい感じです。

サンプルは以下。

public class HTTPSample {

    private static HttpClient httpClient = new DefaultHttpClient();

    public static void main(String[] args) {

        // プロキシがある場合は、以下のようにして設定する
        //HttpHost proxy = new HttpHost("XXX.XXX.XXX.XXX", 8080);
        //httpClient.getParams().setParameter(ConnRoutePNames.DEFAULT_PROXY, proxy);

        Map<String, String> requestParams = new HashMap<String, String>();
        requestParams.put("pattern", "ltrim");
        requestParams.put("lang", "ja");

        httpGet("http://jp2.php.net/manual-lookup.php", requestParams);
        // httpPost("http://jp2.php.net/manual-lookup.php", requestParams);

        // HTTP接続を閉じる(shutdownを実行するとセッションが切れます)
        httpClient.getConnectionManager().shutdown();
    }

    private static void httpGet(String url, Map<String, String> requestParams) {

        HttpGet httpGet = null;

        try {
            // リクエストパラメータの設定
            StringBuilder builder = new StringBuilder(url);
            builder.append("?");
            for (Map.Entry<String, String> entry : requestParams.entrySet()) {
                builder.append((String) entry.getKey());
                builder.append("=");
                builder.append((String) entry.getValue());
                builder.append("&");
            }

            String tmpUrl = builder.toString();
            tmpUrl = tmpUrl.substring(0, tmpUrl.length() - 1);

            httpGet = new HttpGet(tmpUrl);

            System.out.println("executing request " + httpGet.getURI());
            System.out.println("-------------------------------------");

            HttpResponse response = httpClient.execute(httpGet);

            // レスポンスヘッダーの取得
            System.out.println(response.getStatusLine().getStatusCode());

            Header[] headers = response.getAllHeaders();
            for (Header header : headers) {
                System.out.println(header.getName() + ": " + header.getValue());
            }

            System.out.print(System.getProperty("line.separator"));

            // レスポンスボディの取得
            HttpEntity httpEntity = response.getEntity();
            System.out.println(EntityUtils.toString(httpEntity));

        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (httpGet != null) {
                httpGet.abort();
            }
        }
    }

    private static void httpPost(String url, Map<String, String> requestParams) {

        HttpPost httpPost = null;

        try {
            // リクエストパラメータの設定
            List<NameValuePair> params = new ArrayList<NameValuePair>();
            for (Map.Entry<String, String> entry : requestParams.entrySet()) {
                params.add(new BasicNameValuePair((String) entry.getKey(), (String) entry.getValue()));
            }

            httpPost = new HttpPost(url);
            httpPost.setEntity(new UrlEncodedFormEntity(params, HTTP.UTF_8));

            System.out.println("executing request " + httpPost.getURI());
            System.out.println("-------------------------------------");

            // レスポンスヘッダーの取得
            HttpResponse response = httpClient.execute(httpPost);
            System.out.println(response.getStatusLine().getStatusCode());

            Header[] headers = response.getAllHeaders();
            for (Header header : headers) {
                System.out.println(header.getName() + ": " + header.getValue());
            }

            System.out.print(System.getProperty("line.separator"));

            // レスポンスボディの取得
            HttpEntity httpEntity = response.getEntity();
            System.out.println(EntityUtils.toString(httpEntity));

        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (httpPost != null) {
                httpPost.abort();
            }
        }
    }
}

参考

iBATISのSqlMapConfig.xmlについて

SqlMapConfig.xmlの設定を書いておきます。
正直、コネクションプーリングとか遅延ローディングだとかよく分からなかったので、そこらへんはとりあえずデフォルト設定にしておいたほうがいいかも。
分かるようになったら更新します。

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE sqlMapConfig PUBLIC "-//iBATIS.com//DTD SQL Map Config 2.0//EN"
        "http://www.ibatis.com/dtd/sql-map-config-2.dtd">

<sqlMapConfig>

    <!--
        sqlMapClientの最適化を行う(この<settings>エレメントは任意)
        maxRequests : 一度にSQLを実行するスレッドの最大数
                    (maxRequests > maxTransactions*10)
        maxSessions : 一時にアクティブになることができるセッション数
                    (maxTransactions < maxRequests < maxRequests)
        maxTransactions : 一度にSqlMapClient.startTransaction()に入ることができるスレッドの最大数
                        (maxTransactions < maxSessions && maxTransactions << maxRequests)
        cacheModelsEnabled : キャッシュを有効にするかどうか
        lazyLoadingEnabled : 遅延ローディングを有効にするかどうか
        enhancementEnabled : lazyLoadingの拡張?
        useStatementNamespaces : prepared statementsのローカルキャッシュを使用するかどうか
        defaultStatementTimeout : ?よくわからない
        classInfoCacheEnabled : キャッシュされたクラスを使用するかどうか
        statementCachingEnabled : prepared statementsのローカルキャッシュを使用するかどうか

        ちなみに以下の値はすべてデフォルト値です。
    -->
    <settings
        maxRequests="512"
        maxSessions="128"
        maxTransactions="32"
        cacheModelsEnabled="true"
        lazyLoadingEnabled="true"
        enhancementEnabled="true"
        useStatementNamespaces="false"
        classInfoCacheEnabled="true"
        statementCachingEnabled="true"
    />

    <!--
        トランザクション管理サービスの設定
    -->
    <transactionManager type="JDBC">
        <dataSource type="SIMPLE">
            <property name="JDBC.Driver" value="org.postgresql.Driver" />
            <property name="JDBC.ConnectionURL" value="jdbc:postgresql://localhost:5432/sampledb" />
            <property name="JDBC.Username" value="postgres" />
            <property name="JDBC.Password" value="postgres" />
            <property name="JDBC.DefaultAutoCommit" value="false" />
            <!-- コネクションプーリング(はっきりいってよく分からない部分なので書かないでおいたほうが無難かも。。) -->
            <property name="Pool.MaximumActiveConnections" value="10" />
            <property name="Pool.MaximumIdleConnections" value="5" />
            <property name="Pool.MaximumCheckoutTime" value="120000" />
            <property name="Pool.TimeToWait" value="10000" />
            <property name="Pool.PingQuery" value="select 1" />
            <property name="Pool.PingEnabled" value="false" />
            <property name="Pool.PingConnectionsOlderThan" value="0" />
            <property name="Pool.PingConnectionsNotUsedFor" value="0" />
        </dataSource>
    </transactionManager>

    <!-- sqlMapファイルの参照 -->
    <sqlMap resource="ibatis/dao/user.SqlMap.xml" />
</sqlMapConfig>

参考

iBATISでトランザクションする

iBATISのデフォルト設定だと自動コミットモードになっていて、細かなトランザクション処理ができません。なので、iBATISでトランザクションをできるようにしてみる。
設定・構成等はiBATIS入門と同じです。

自動コミットモードの解除

まずSqlMapConfig.xmlを編集して、自動コミットモードを解除しておきます。
大事なのは、「<property name=”JDBC.DefaultAutoCommit” value=”false” />」です。

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE sqlMapConfig PUBLIC "-//iBATIS.com//DTD SQL Map Config 2.0//EN"
        "http://www.ibatis.com/dtd/sql-map-config-2.dtd">

<sqlMapConfig>
    <!-- DB接続設定 -->
    <transactionManager type="JDBC">
        <dataSource type="SIMPLE">
            <property name="JDBC.Driver" value="org.postgresql.Driver" />
            <property name="JDBC.ConnectionURL" value="jdbc:postgresql://localhost:5432/sampledb" />
            <property name="JDBC.Username" value="postgres" />
            <property name="JDBC.Password" value="postgres" />
            <property name="JDBC.DefaultAutoCommit" value="false" />
        </dataSource>
    </transactionManager>

    <!-- sqlMapファイルの参照 -->
    <sqlMap resource="ibatis/dao/user.SqlMap.xml" />
</sqlMapConfig>

実際に動かしてみる

sqlMap.startTransaction()でトランザクションを開始して、sqlMap.commitTransaction()でコミットする。
正常・異常終了に関わらずfinallyでsqlMap.endTransaction()をする。
トランザクション処理を行う場合はこのパターンが定型だと思われる。

package ibatis;

import ibatis.dto.User;
import com.ibatis.sqlmap.client.SqlMapClient;
import java.sql.SQLException;

public class Sample {

    public static void main(String[] args) {
        // SqlMapClientを生成
        SqlMapClient sqlMap = MyAppSqlConfig.getSqlMapInstance();

        try {
            // トランザクションを開始する
            sqlMap.startTransaction();

            // insert
            User user = new User();
            user.setId(4);
            user.setName("Tanaka");
            user.setAge(35);
            sqlMap.insert("insertUser", user);

            // delete
            sqlMap.delete("deleteUser", 1);

            // コミットする
            sqlMap.commitTransaction();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                // トランザクションを終了する
                // commitTransaction()まで行かず、エラーが発生した場合はロールバックを行う
                sqlMap.endTransaction();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

Javaでファイルを1行ずつ読み込む

  • Posted by: sinsengumi
  • 8:06 PM
  • Java

Javaでファイルを読み込み、1行ずつ出力する処理。よく書くので。

public void fileRead(String filePath) {
    FileReader fr = null;
    BufferedReader br = null;
    try {
        fr = new FileReader(filePath);
        br = new BufferedReader(fr);

        String line;
        while ((line = br.readLine()) != null) {
            System.out.println(line);
        }
    } catch (FileNotFoundException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        try {
            br.close();
            fr.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Javaでファイルの拡張子を取得する

  • Posted by: sinsengumi
  • 6:41 PM
  • Java

JavaのFileクラスを利用して、そのファイルの拡張子を取得します。

public String getSuffix(File path) {
    if (path.isDirectory()) {
        return null;
    }

    String fileName = path.getName();

    int lastDotPosition = fileName.lastIndexOf(".");
    if (lastDotPosition != -1) {
        return fileName.substring(lastDotPosition + 1);
    }
    return null;
}

Home > Tags > Java

Search
Feeds
Meta

Return to page top