CREATE TYPE keyvaluepair AS (
	key varchar( 10 ),
	value varchar( 200 )
);

package comp_type;

import java.sql.SQLException;
import org.postgresql.util.PGtokenizer;

public class PgPair extends org.postgresql.util.PGobject implements Cloneable {
    private String key;
    private String val;
    
    /** Creates a new instance of PgPair */
    public PgPair() {
        setType("keyvaluepair");
    }
    
    public PgPair(String key, String val) {
        this();
        this.key = key;
        this.val = val;
    }
    
    public String getKey() {
        return key;
    }
    
    public String getVal() {
        return val;
    }
    
    public void setValue(String value) throws SQLException {
        String s = value.substring( 1 , value.length()- 1 );
        PGtokenizer t = new PGtokenizer(s, ',');
        if(t.getSize() !=  2 ) throw new SQLException("Failed to convert to type PgPair.");
        key = t.getToken( 0 );
        val = t.getToken( 1 );
    }
    
    public boolean equals(Object obj) {
        if(obj instanceof PgPair) {
            PgPair p = (PgPair) obj;
            return p.getKey().equals(key) && p.getVal().equals(val);
        } else {
            return false;
        }
    }
    
    public int hashCode() {
        return key.hashCode() ^ val.hashCode();
    }
    
    public String getValue() {
        return "('" + key.toString() + "','" + val.toString() + "')";
     }
    
    public Object clone() {
        return new PgPair(key, val);
    }
    
    public String toString(){
        return "key: " + key + " value: " + val;
    }
}

((org.postgresql.PGConnection)connection).addDataType("keyvaluepair",PgPair.class);

    public static void insert(){
        PgPair pair = new PgPair("X\"", "XXX");
        String sql = "insert into part1.tblxxx (id, value) " +
                "values ( 1 , ?)";
        try {
            PreparedStatement ps = connection.prepareStatement(sql);
            ps.setObject( 1 , pair);
            ps.executeUpdate();
        } catch (SQLException ex) {
            System.out.println(ex.getMessage());
        }
    }

    private String quoteString(String s){
        return s.replace("\"", "\"\"").replace("\\","\\\\");
    }
    
    private String unQuoteString(String s){
        return (s.charAt(0) == '"') ? s.substring(1, s.length()-1).replace("\"\"","\"").replace("\\\\", "\\") : s;
    }

    public String getValue() {
        return "(\"" + quoteString(key) + "\",\"" + quoteString(val) + "\")";
     }

    public void setValue(String value) throws SQLException {
        String s = value.substring( 1 , value.length()- 1 );
        PGtokenizer t = new PGtokenizer(s, ',');
        if(t.getSize() !=  2 ) throw new SQLException("Failed to convert to type PgPair.");
        key = unQuoteString(t.getToken( 0 ));
        val = unQuoteString(t.getToken( 1 ));
    }