Skip to content

Instantly share code, notes, and snippets.

@robshep
Created June 5, 2015 16:13
Show Gist options
  • Save robshep/b0946559dcf7eedfb9bb to your computer and use it in GitHub Desktop.
Save robshep/b0946559dcf7eedfb9bb to your computer and use it in GitHub Desktop.
PostgreSQL JSON DataType binding using Jackson
import java.io.IOException;
import java.io.Serializable;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.util.Properties;
import org.hibernate.HibernateException;
import org.hibernate.engine.spi.SessionImplementor;
import org.hibernate.internal.util.ReflectHelper;
import org.hibernate.type.Type;
import org.hibernate.usertype.CompositeUserType;
import org.hibernate.usertype.ParameterizedType;
import org.hibernate.usertype.UserType;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.base.Objects;
public class PGJSONSerialiser implements UserType, ParameterizedType, Serializable
{
private static final long serialVersionUID = 1L;
private static final ObjectMapper MAPPER = new ObjectMapper();
public static final String CLASS_TYPE = "classType";
private static final int[] SQL_TYPES = new int[] { Types.JAVA_OBJECT };
private Class<?> classType;
private int sqlType = Types.LONGVARCHAR; // before any guessing
@Override
public void setParameterValues(Properties params) {
String classTypeName = params.getProperty(CLASS_TYPE);
try {
this.classType = ReflectHelper.classForName(classTypeName, this.getClass());
} catch (ClassNotFoundException cnfe) {
throw new HibernateException("classType not found", cnfe);
}
this.sqlType = Types.OTHER;
}
@Override
public Object assemble(Serializable cached, Object owner) throws HibernateException {
return this.deepCopy(cached);
}
@Override
public Object deepCopy(Object value) throws HibernateException {
Object copy = null;
if (value != null) {
try {
return MAPPER.readValue(MAPPER.writeValueAsString(value), this.classType);
} catch (IOException e) {
throw new HibernateException("unable to deep copy object", e);
}
}
return copy;
}
@Override
public Serializable disassemble(Object value) throws HibernateException {
try {
return MAPPER.writeValueAsString(value);
} catch (JsonProcessingException e) {
throw new HibernateException("unable to disassemble object", e);
}
}
@Override
public boolean equals(Object x, Object y) throws HibernateException {
return Objects.equal(x, y);
}
@Override
public int hashCode(Object x) throws HibernateException {
return Objects.hashCode(x);
}
@Override
public boolean isMutable() {
return true;
}
@Override
public Object nullSafeGet(ResultSet rs, String[] names, SessionImplementor session, Object owner) throws HibernateException, SQLException {
Object obj = null;
String jsonValueString = rs.getString(names[0]);
if (!rs.wasNull()) {
try {
obj = MAPPER.readValue(jsonValueString, this.classType);
} catch (IOException e) {
throw new HibernateException("unable to read object from result set", e);
}
}
return obj;
}
@Override
public void nullSafeSet(PreparedStatement st, Object value, int index, SessionImplementor session) throws HibernateException, SQLException {
if (value == null) {
st.setNull(index, this.sqlType);
} else {
try {
st.setObject(index, MAPPER.writeValueAsString(value), this.sqlType);
} catch (JsonProcessingException e) {
throw new HibernateException("unable to set object to result set", e);
}
}
}
@Override
public Object replace(Object original, Object target, Object owner) throws HibernateException {
return this.deepCopy(original);
}
@Override
public Class<?> returnedClass() {
return this.classType;
}
@Override
public int[] sqlTypes() {
return SQL_TYPES;
}
}
@marcianorama
Copy link

this is required java 8 or 7 ?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment