PostgreSQL 6.3.2 JDBC ドライバ MB サポートパッチ    1998 9/30

 このパッチは、PostgreSQL 6.3.2 に付属の JDBC ドライバを、
バックエンドとやりとりする文字列のエンコーディングを指定できるよう
拡張します。

 src/interfaces/jdbc/ の下で、

    % patch -p1 < このファイル

でパッチをあてて下さい。使い方は、src/interfaces/jdbc/ に 
README.mb.eucjp というファイルができるので、それを読んで下さい。

diff -urN jdbc-6.3.2.ORIG/README.mb.eucjp jdbc-6.3.2-mb/README.mb.eucjp
--- jdbc-6.3.2.ORIG/README.mb.eucjp	Thu Jan  1 09:00:00 1970
+++ jdbc-6.3.2-mb/README.mb.eucjp	Wed Sep 30 20:56:46 1998
@@ -0,0 +1,77 @@
+
+	$Id: README.mb.eucjp,v 1.3 1998/09/30 11:56:29 mochid Exp mochid $
+
+PostgreSQL 6.3.2 JDBC ドライバ MB サポート
+
+   PostgreSQL 6.3.2 に付属の JDBC ドライバを、バックエンドとやりとりする
+  文字列のエンコーディングを指定できるよう拡張します。エンコーディングは、
+  石井達夫さんの mb_b3.patch で使用できるもののうちの
+
+      EUC_JP
+      UNICODE
+
+  と(*1)、mb_b3.patch でのエンコーディング名と Java での
+  エンコーディング名が同じものが使用できます(*2)。
+
+使い方:
+   postgresql.databaseencoding という Java のプロパティにバックエンドの
+  エンコーディングを指定します。例えば、
+
+      -Dpostgresql.databaseencoding=EUC_JP
+
+  とします。
+
+
+  *1 MULE_INTERNAL はサポートしていません。JDK の配布に含まれる
+     エンコーディング変換機能を利用しているため、MULE_INTERNAL は
+     変換できません。コンバータ書いたからマージしてよ、という方は
+     連絡下さい。
+  *2 JDK 1.1.6 以降では、EUC_KR, EUC_CN, EUC_TW が使用できます。
+     1.1.5 以前ではこれらは使えません。
+  *3 いちいち -Dpostgresql.databaseencoding= を指定するのは面倒だ、
+     という方は、Connection.java を編集して、databaseEncoding の初期値を
+     直接指定して下さい。プロパティに無指定の場合はその値が使用される様に
+     なります。
+
+      String databaseEncoding = null;		// set default encoding
+                                 ↓
+      String databaseEncoding = "EUC_JP";	// set default encoding
+
+
+注意:
+   このパッチは、無保証です。このパッチによってなんらかの損害が発生する
+  可能性がありますので、自らの責任において使用して下さい。
+   再配布は自由に行ってもらって結構です。ただし、修正されたものを
+  配布される場合は、その旨を明記して下さい。修正されたものについての
+  問い合わせ等には応じかねます。
+
+履歴:
+   このパッチは、たかばとしはる さんが「jdbc UTF8 patch」として 
+  pgsql-jp メーリングリスト [pgsql-jp 3617] で公開されたものを、
+  持田 修司 mochid@yo.rim.or.jp が他のエンコーディングでも
+  利用できるように修正したものです。
+
+その他:
+
+  1) Java とシステム間のエンコーディングについて:
+
+     バックエンドと JDBC ドライバ間のエンコーディングと、
+    Java とシステム間のエンコーディングは区別する必要があります。
+     Java とシステム間のエンコーディングは、Java が正式にサポートしている
+    プラットホームではあまり意識する必要はありません。ですが、
+    Java が正式にサポートしていないプラットホームでは、
+    これを明示的に指定してやる必要があります。
+     例えば NetBSD/i386 1.3.2 + JDK 1.1.5 (http://www.quick.com.au/java/)
+    では、
+
+      -Dfile.encoding=EUCJIS -Duser.language=ja
+
+    とすることで日本語 EUC を使用するよう指示することができています。
+
+関連情報:
+  このパッチ用のページ（'98 9/30 現在、まだ準備中です）
+      http://www.yo.rim.or.jp/~mochid/postgresql-jdbc/
+  PostgreSQL ML
+      http://www.sra.co.jp/people/t-ishii/postgres95/ML/info.html
+
+# End of file
diff -urN jdbc-6.3.2.ORIG/postgresql/Connection.java jdbc-6.3.2-mb/postgresql/Connection.java
--- jdbc-6.3.2.ORIG/postgresql/Connection.java	Sun Apr 19 16:00:31 1998
+++ jdbc-6.3.2-mb/postgresql/Connection.java	Sun Sep 27 12:21:57 1998
@@ -53,7 +53,7 @@
   //private static final int STARTUP_HBA  = 12;	// Host Based
   //private static final int STARTUP_NONE = 13;	// Unauthenticated (unused)
   //private static final int STARTUP_PASS = 14;	// Password auth
-  
+
   private boolean autoCommit = true;
   private boolean readOnly = false;
   
@@ -122,6 +122,40 @@
   // Now handle notices as warnings, so things like "show" now work
   protected SQLWarning firstWarning = null;
   
+  // Encoding string PostgreSQL -> Java mapping
+  class EncodingTable extends Hashtable
+  {
+    final String[] encodingStrs = {
+      "EUC_JP", "EUCJIS",		/* use EUCJIS for JDK 1.1.5 */
+      "UNICODE", "UTF8"
+      /* "MULE_INTERNAL" is not supported */
+    };
+
+    EncodingTable()
+    {
+      super();
+      for (int i = 0, len = encodingStrs.length; i < len;)
+	this.put(encodingStrs[i++], encodingStrs[i++]);
+    }
+
+    // convert encoding name to Java complient
+    private String mapString(String instr)
+    {
+      if (instr == null)
+	return null;
+      String ecMapped = (String)this.get(instr);
+      if (ecMapped != null)
+	return ecMapped;
+      else
+	return instr;
+    }
+  };
+
+  static String dbEncodingPropName = "postgresql.databaseencoding";
+
+  boolean needConvertEncodingFlag = false;	// need encoding conversion
+  String databaseEncoding = null;		// set default encoding
+
   /**
    * Connect to a PostgreSQL database back end.
    *
@@ -181,7 +215,7 @@
     //// Anything else defaults to trust authentication
     //STARTUP_CODE=STARTUP_USER;
     //}
-    
+
     // Now make the initial connection
     try
       {
@@ -298,7 +332,42 @@
 	
 	// Initialise object handling
 	initObjectTypes();
-	
+
+	// Get Database encoding
+	EncodingTable ecTbl = new EncodingTable();
+	databaseEncoding = ecTbl.mapString(databaseEncoding);
+
+	// get from Java Property
+	String encoding = System.getProperty(dbEncodingPropName);
+	encoding = ecTbl.mapString(encoding);
+	// get from database
+	ResultSet r = null;
+	try{
+	  r = ExecSQL("select getdatabaseencoding()");
+	} catch(SQLException e) {
+	// do nothing.
+	}
+	if (r != null) {
+	  r.next();
+	  String ecFromDb = r.getString(1);
+	  ecFromDb = ecTbl.mapString(ecFromDb);
+	  if ((!ecFromDb.equals("SQL_ASCII"))
+	       && encoding != null && (!ecFromDb.equals(encoding)))
+	    throw new SQLException("Encoding " + encoding
+		       + " does not match with database's " + ecFromDb + ".");
+	  if (encoding == null)
+	    encoding = ecFromDb;
+	}
+	if (encoding != null)
+	  databaseEncoding = encoding;
+
+	if (databaseEncoding == null || databaseEncoding.equals("SQL_ASCII"))
+	  needConvertEncodingFlag = false;
+	else
+	  needConvertEncodingFlag = true;
+
+	pg_stream.cacheEncoding(this);
+
 	// Mark the connection as ok, and cleanup
 	clearWarnings();
 	PG_STATUS = CONNECTION_OK;
@@ -681,7 +750,15 @@
     try
       {
 	pg_stream.SendChar('Q');
-	buf = sql.getBytes();
+	if (!needConvertEncodingFlag)
+	  buf = sql.getBytes();
+	else {
+	  try {
+	    buf = sql.getBytes(databaseEncoding);
+	  } catch (UnsupportedEncodingException e) {
+	    throw new SQLException("Encode Error: " + e.toString());
+	  }
+	}
 	pg_stream.Send(buf);
 	pg_stream.SendChar(0);
       } catch (IOException e) {
@@ -982,6 +1059,14 @@
   {
     for(int i=0;i<defaultObjectTypes.length;i++)
       objectTypes.put(defaultObjectTypes[i][0],defaultObjectTypes[i][1]);
+  }
+
+  public boolean needConvertEncoding() {
+    return needConvertEncodingFlag;
+  }
+
+  public String getDatabaseEncoding() {
+    return databaseEncoding;
   }
 }
 
diff -urN jdbc-6.3.2.ORIG/postgresql/DatabaseMetaData.java jdbc-6.3.2-mb/postgresql/DatabaseMetaData.java
--- jdbc-6.3.2.ORIG/postgresql/DatabaseMetaData.java	Mon Mar 23 17:01:22 1998
+++ jdbc-6.3.2-mb/postgresql/DatabaseMetaData.java	Wed Sep 23 19:37:04 1998
@@ -1,5 +1,6 @@
 package postgresql;
 
+import java.io.UnsupportedEncodingException;
 import java.sql.*;
 import java.util.*;
 
@@ -29,6 +30,8 @@
 public class DatabaseMetaData implements java.sql.DatabaseMetaData 
 {
   Connection connection;		// The connection association
+  boolean needConvertEncodingFlag = false;	// need encoding conversion
+  String databaseEncoding = null;		// database encoding
   
   // These define various OID's. Hopefully they will stay constant.
   static final int iVarcharOid = 1043;	// OID for varchar
@@ -40,6 +43,8 @@
   public DatabaseMetaData(Connection conn)
   {
     this.connection = conn;
+    this.needConvertEncodingFlag = this.connection.needConvertEncoding();
+    this.databaseEncoding = this.connection.getDatabaseEncoding();
   }
   
   /**
@@ -1493,15 +1498,31 @@
 	String name = r.getString(1);
 	remarks = new String("no remarks");
 	boolean retset = r.getBoolean(2);
-	
-	tuple[0] = null;			// Catalog name
-	tuple[1] = null;			// Schema name
-	tuple[2] = name.getBytes();	// Procedure name
-	tuple[3] = null;			// Reserved
-	tuple[4] = null;			// Reserved
-	tuple[5] = null;			// Reserved
-	tuple[6] = remarks.getBytes();	// Remarks
-	tuple[7] = new byte[1];
+
+	if (!needConvertEncodingFlag) {
+	  tuple[0] = null;			// Catalog name
+	  tuple[1] = null;			// Schema name
+	  tuple[2] = name.getBytes();	// Procedure name
+	  tuple[3] = null;			// Reserved
+	  tuple[4] = null;			// Reserved
+	  tuple[5] = null;			// Reserved
+	  tuple[6] = remarks.getBytes();	// Remarks
+	  tuple[7] = new byte[1];
+	}
+	else {
+	  try {
+	    tuple[0] = null;			// Catalog name
+	    tuple[1] = null;			// Schema name
+	    tuple[2] = name.getBytes(databaseEncoding);	// Procedure name
+	    tuple[3] = null;			// Reserved
+	    tuple[4] = null;			// Reserved
+	    tuple[5] = null;			// Reserved
+	    tuple[6] = remarks.getBytes(databaseEncoding);	// Remarks
+	    tuple[7] = new byte[1];
+	  } catch (UnsupportedEncodingException e) {
+	    throw new SQLException("Encode Error: " + e.toString());
+	  }
+	}
 	if (retset)
 	  tuple[7][0] = (byte)java.sql.DatabaseMetaData.procedureReturnsResult;
 	else
@@ -1665,11 +1686,24 @@
 	}
 	dr.close();
 	
-	tuple[0] = null;			// Catalog name
-	tuple[1] = null;			// Schema name
-	tuple[2] = name.getBytes();		// Table name
-	tuple[3] = null;			// Table type
-	tuple[4] = remarks.getBytes();		// Remarks
+	if (!needConvertEncodingFlag) {
+	  tuple[0] = null;			// Catalog name
+	  tuple[1] = null;			// Schema name
+	  tuple[2] = name.getBytes();		// Table name
+	  tuple[3] = null;			// Table type
+	  tuple[4] = remarks.getBytes();	// Remarks
+	}
+	else {
+	  try {
+	    tuple[0] = null;			// Catalog name
+	    tuple[1] = null;			// Schema name
+	    tuple[2] = name.getBytes(databaseEncoding);	// Table name
+	    tuple[3] = null;			// Table type
+	    tuple[4] = remarks.getBytes(databaseEncoding);	// Remarks
+	  } catch (UnsupportedEncodingException e) {
+	    throw new SQLException("Encode Error: " + e.toString());
+	  }
+	}
 	v.addElement(tuple);
       }
     r.close();
@@ -1718,7 +1752,15 @@
     Vector v = new Vector();
     byte[][] tuple = new byte[1][0];
     f[0] = new Field(connection,new String("TABLE_SCHEM"),iVarcharOid,32);
-    tuple[0] = "".getBytes();
+    if (!needConvertEncodingFlag)
+      tuple[0] = "".getBytes();
+    else {
+      try {
+	tuple[0] = "".getBytes(databaseEncoding);
+      } catch (UnsupportedEncodingException e) {
+	throw new SQLException("Encode Error: " + e.toString());
+      }
+    }
     v.addElement(tuple);
     return new ResultSet(connection,f,v,"OK",1);
   }
@@ -1742,7 +1784,15 @@
     Vector v = new Vector();
     byte[][] tuple = new byte[1][0];
     f[0] = new Field(connection,new String("TABLE_CAT"),iVarcharOid,32);
-    tuple[0] = "".getBytes();
+    if (!needConvertEncodingFlag)
+      tuple[0] = "".getBytes();
+    else {
+      try {
+	tuple[0] = "".getBytes(databaseEncoding);
+      } catch (UnsupportedEncodingException e) {
+	throw new SQLException("Encode Error: " + e.toString());
+      }
+    }
     v.addElement(tuple);
     return new ResultSet(connection,f,v,"OK",1);
   }
@@ -1767,9 +1817,21 @@
     Vector v = new Vector();
     byte[][] tuple = new byte[1][0];
     f[0] = new Field(connection,new String("TABLE_TYPE"),iVarcharOid,32);
-    for(int i=0;i<getTableTypes.length;i++) {
-      tuple[0] = getTableTypes[i][0].getBytes();
-      v.addElement(tuple);
+    if (!needConvertEncodingFlag) {
+      for(int i=0;i<getTableTypes.length;i++) {
+	tuple[0] = getTableTypes[i][0].getBytes();
+	v.addElement(tuple);
+      }
+    }
+    else {
+      try {
+	for(int i=0;i<getTableTypes.length;i++) {
+	  tuple[0] = getTableTypes[i][0].getBytes(databaseEncoding);
+	  v.addElement(tuple);
+	}
+      } catch (UnsupportedEncodingException e) {
+	throw new SQLException("Encode Error: " + e.toString());
+      }
     }
     return new ResultSet(connection,f,v,"OK",1);
   }
@@ -1866,17 +1928,39 @@
 	}
 	dr.close();
 	
-	tuple[0] = "".getBytes();	// Catalog name
-	tuple[1] = "".getBytes();	// Schema name
-	tuple[2] = r.getString(2).getBytes();	// Table name
-	tuple[3] = r.getString(3).getBytes();	// Column name
+	if (!needConvertEncodingFlag) {
+	  tuple[0] = "".getBytes();	// Catalog name
+	  tuple[1] = "".getBytes();	// Schema name
+	  tuple[2] = r.getString(2).getBytes();	// Table name
+	  tuple[3] = r.getString(3).getBytes();	// Column name
+	}
+	else {
+	  try {
+	    tuple[0] = "".getBytes(databaseEncoding);	// Catalog name
+	    tuple[1] = "".getBytes(databaseEncoding);	// Schema name
+	    tuple[2] = r.getString(2).getBytes(databaseEncoding);	// Table name
+	    tuple[3] = r.getString(3).getBytes(databaseEncoding);	// Column name
+	  } catch (UnsupportedEncodingException e) {
+	    throw new SQLException("Encode Error: " + e.toString());
+	  }
+	}
 	
 	dr = connection.ExecSQL("select typname from pg_type where oid = "+r.getString(4));
 	dr.next();
 	String typname=dr.getString(1);
 	dr.close();
-	tuple[4] = Integer.toString(Field.getSQLType(typname)).getBytes();	// Data type
-	tuple[5] = typname.getBytes();	// Type name
+	if (!needConvertEncodingFlag) {
+	  tuple[4] = Integer.toString(Field.getSQLType(typname)).getBytes();	// Data type
+	  tuple[5] = typname.getBytes();	// Type name
+	}
+	else {
+	  try {
+	    tuple[4] = Integer.toString(Field.getSQLType(typname)).getBytes(databaseEncoding);	// Data type
+	    tuple[5] = typname.getBytes(databaseEncoding);	// Type name
+	  } catch (UnsupportedEncodingException e) {
+	    throw new SQLException("Encode Error: " + e.toString());
+	  }
+	}
 
 	// Looking at the psql source,
 	// I think the length of a varchar as specified when the table was created
@@ -1886,29 +1970,43 @@
 	  columnSize = Integer.toString(atttypmod != -1 ? atttypmod - VARHDRSZ : 0);
 	} else
 	  columnSize = r.getString(7);
-	tuple[6] = columnSize.getBytes();	// Column size
-	
-	tuple[7] = null;	// Buffer length
-	
-	tuple[8] = "0".getBytes();	// Decimal Digits - how to get this?
-	tuple[9] = "10".getBytes();	// Num Prec Radix - assume decimal
-	
-	// tuple[10] is below
-	
-	tuple[11] = remarks.getBytes();		// Remarks
-	
-	tuple[12] = null;	// column default
-	
-	tuple[13] = null;	// sql data type (unused)
-	tuple[14] = null;	// sql datetime sub (unused)
-	
-	tuple[15] = tuple[6];	// char octet length
-	
-	tuple[16] = r.getString(5).getBytes();	// ordinal position
-	
-	String nullFlag = r.getString(6);
-	tuple[10] = Integer.toString(nullFlag.equals("f")?java.sql.DatabaseMetaData.columnNullable:java.sql.DatabaseMetaData.columnNoNulls).getBytes();	// Nullable
-	tuple[17] = (nullFlag.equals("f")?"YES":"NO").getBytes();	// is nullable
+
+	if (!needConvertEncodingFlag) {
+	  tuple[6] = columnSize.getBytes();	// Column size
+	  tuple[7] = null;	// Buffer length
+	  tuple[8] = "0".getBytes();	// Decimal Digits - how to get this?
+	  tuple[9] = "10".getBytes();	// Num Prec Radix - assume decimal
+	  // tuple[10] is below
+	  tuple[11] = remarks.getBytes();		// Remarks
+	  tuple[12] = null;	// column default
+	  tuple[13] = null;	// sql data type (unused)
+	  tuple[14] = null;	// sql datetime sub (unused)
+	  tuple[15] = tuple[6];	// char octet length
+	  tuple[16] = r.getString(5).getBytes();	// ordinal position
+	  String nullFlag = r.getString(6);
+	  tuple[10] = Integer.toString(nullFlag.equals("f")?java.sql.DatabaseMetaData.columnNullable:java.sql.DatabaseMetaData.columnNoNulls).getBytes();	// Nullable
+	  tuple[17] = (nullFlag.equals("f")?"YES":"NO").getBytes();	// is nullable
+	}
+	else {
+	  try {
+	    tuple[6] = columnSize.getBytes(databaseEncoding);	// Column size
+	    tuple[7] = null;	// Buffer length
+	    tuple[8] = "0".getBytes(databaseEncoding);	// Decimal Digits - how to get this?
+	    tuple[9] = "10".getBytes(databaseEncoding);	// Num Prec Radix - assume decimal
+	    // tuple[10] is below
+	    tuple[11] = remarks.getBytes(databaseEncoding);		// Remarks
+	    tuple[12] = null;	// column default
+	    tuple[13] = null;	// sql data type (unused)
+	    tuple[14] = null;	// sql datetime sub (unused)
+	    tuple[15] = tuple[6];	// char octet length
+	    tuple[16] = r.getString(5).getBytes(databaseEncoding);	// ordinal position
+	    String nullFlag = r.getString(6);
+	    tuple[10] = Integer.toString(nullFlag.equals("f")?java.sql.DatabaseMetaData.columnNullable:java.sql.DatabaseMetaData.columnNoNulls).getBytes(databaseEncoding);	// Nullable
+	    tuple[17] = (nullFlag.equals("f")?"YES":"NO").getBytes(databaseEncoding);	// is nullable
+	  } catch (UnsupportedEncodingException e) {
+	    throw new SQLException("Encode Error: " + e.toString());
+	  }
+	}
 	
 	v.addElement(tuple);
       }
@@ -1961,7 +2059,15 @@
     ResultSet r = connection.ExecSQL("SELECT relname, relacl FROM pg_class, pg_user WHERE ( relkind = 'r' OR relkind = 'i') and relname !~ '^pg_' and relname !~ '^xin[vx][0-9]+' and usesysid = relowner ORDER BY relname");
     while(r.next()) {
       byte[][] tuple = new byte[8][0];
-      tuple[0] = tuple[1]= "".getBytes();
+      if (!needConvertEncodingFlag)
+	tuple[0] = tuple[1]= "".getBytes();
+      else {
+	try {
+	  tuple[0] = tuple[1]= "".getBytes(databaseEncoding);
+	} catch (UnsupportedEncodingException e) {
+	  throw new SQLException("Encode Error: " + e.toString());
+	}
+      }
       DriverManager.println("relname=\""+r.getString(1)+"\" relacl=\""+r.getString(2)+"\"");
       //v.addElement(tuple);
     }
diff -urN jdbc-6.3.2.ORIG/postgresql/PG_Stream.java jdbc-6.3.2-mb/postgresql/PG_Stream.java
--- jdbc-6.3.2.ORIG/postgresql/PG_Stream.java	Mon Feb  2 22:16:53 1998
+++ jdbc-6.3.2-mb/postgresql/PG_Stream.java	Wed Sep 23 19:37:03 1998
@@ -21,7 +21,11 @@
   private Socket connection;
   private InputStream pg_input;
   private OutputStream pg_output;
-  
+
+  // for charactor encoding conversion
+  boolean needConvertEncodingFlag = false;	// need encoding conversion
+  String databaseEncoding = null;
+
   /**
    * Constructor:  Connect to the PostgreSQL back end and return
    * a stream connection.
@@ -34,7 +38,7 @@
   {
     connection = new Socket(host, port);
     pg_input = connection.getInputStream();
-    pg_output = connection.getOutputStream();	
+    pg_output = connection.getOutputStream();
   }
   
   /**
@@ -239,7 +243,7 @@
   {
     byte[] rst = new byte[maxsiz];
     int s = 0;
-    
+   
     try
       {
 	while (s < maxsiz)
@@ -257,8 +261,18 @@
       } catch (IOException e) {
 	throw new SQLException("Error reading from backend: " + e.toString());
       }
-      String v = new String(rst, 0, s);
-      return v;
+    String v = null;
+    if (!needConvertEncodingFlag)
+      v = new String(rst, 0, s);
+    else {
+      try
+	{
+	  v = new String(rst, 0, s, databaseEncoding);
+	} catch (UnsupportedEncodingException e) {
+	  throw new SQLException("Encode Error: " + e.toString());
+	}
+    }
+    return v;
   }
   
   /**
@@ -381,5 +395,11 @@
     pg_output.close();
     pg_input.close();
     connection.close();
+  }
+
+  public void cacheEncoding(Connection jdbcConn)
+  {
+    needConvertEncodingFlag = jdbcConn.needConvertEncoding();
+    databaseEncoding = jdbcConn.getDatabaseEncoding();
   }
 }
diff -urN jdbc-6.3.2.ORIG/postgresql/ResultSet.java jdbc-6.3.2-mb/postgresql/ResultSet.java
--- jdbc-6.3.2.ORIG/postgresql/ResultSet.java	Sun Apr 19 16:00:32 1998
+++ jdbc-6.3.2-mb/postgresql/ResultSet.java	Wed Sep 23 19:37:03 1998
@@ -61,7 +61,9 @@
   Connection connection;	// the connection which we returned from
   SQLWarning warnings = null;	// The warning chain
   boolean wasNullFlag = false;	// the flag for wasNull()
-  
+  boolean needConvertEncodingFlag = false;	// need encoding conversion
+  String databaseEncoding = null;		// database encoding
+
   //  We can chain multiple resultSets together - this points to
   // next resultSet in the chain.
   private ResultSet next = null;
@@ -86,6 +88,8 @@
     this.updateCount = updateCount;
     this.this_row = null;
     this.current_row = -1;
+    this.needConvertEncodingFlag = this.connection.needConvertEncoding();
+    this.databaseEncoding = this.connection.getDatabaseEncoding();
   }
   
   /**
@@ -161,7 +165,17 @@
     wasNullFlag = (this_row[columnIndex - 1] == null);
     if(wasNullFlag)
       return null;
-    return new String(this_row[columnIndex - 1]);
+    if (!needConvertEncodingFlag)
+      return new String(this_row[columnIndex - 1]);
+    else {
+      String v = null;
+      try {
+	v = new String(this_row[columnIndex - 1], databaseEncoding);
+      } catch (UnsupportedEncodingException e) {
+	throw new SQLException("Encode Error: " + e.toString());
+      }
+      return v;
+    }
   }
   
   /**