diff options
Diffstat (limited to 'src/main/java/com/iciql/adapter')
9 files changed, 516 insertions, 0 deletions
diff --git a/src/main/java/com/iciql/adapter/GsonTypeAdapter.java b/src/main/java/com/iciql/adapter/GsonTypeAdapter.java new file mode 100644 index 0000000..a85f15e --- /dev/null +++ b/src/main/java/com/iciql/adapter/GsonTypeAdapter.java @@ -0,0 +1,58 @@ +/* + * Copyright 2014 James Moger. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.iciql.adapter; + +import com.google.gson.Gson; +import com.google.gson.GsonBuilder; +import com.iciql.Iciql.DataTypeAdapter; + +/** + * Base class for inserting/retrieving a Java Object (de)serialized as JSON using Google GSON. + * <p>You use this by creating a subclass which defines your object class.</p> + * <pre> + * public class CustomObjectAdapter extends GsonTypeAdapter<CustomObject> { + * + * public Class<CustomObject> getJavaType() { + * return CustomObject.class; + * } + * } + * </pre> + * @param <T> + */ +public abstract class GsonTypeAdapter<T> implements DataTypeAdapter<T> { + + protected Gson gson() { + return new GsonBuilder().create(); + } + + @Override + public String getDataType() { + return "TEXT"; + } + + @Override + public Object serialize(T value) { + return gson().toJson(value); + } + + @Override + public T deserialize(Object value) { + String json = value.toString(); + Gson gson = gson(); + T t = gson.fromJson(json, getJavaType()); + return t; + } +} diff --git a/src/main/java/com/iciql/adapter/JavaSerializationTypeAdapter.java b/src/main/java/com/iciql/adapter/JavaSerializationTypeAdapter.java new file mode 100644 index 0000000..c475817 --- /dev/null +++ b/src/main/java/com/iciql/adapter/JavaSerializationTypeAdapter.java @@ -0,0 +1,100 @@ +/* + * Copyright 2014 James Moger. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.iciql.adapter; + +import java.io.ByteArrayInputStream; +import java.io.ByteArrayOutputStream; +import java.io.IOException; +import java.io.InputStream; +import java.io.ObjectInputStream; +import java.io.ObjectOutputStream; +import java.sql.Blob; +import java.sql.SQLException; + +import com.iciql.Iciql; +import com.iciql.IciqlException; +import com.iciql.Iciql.DataTypeAdapter; + +/** + * Base class for inserting/retrieving a Java Object as a BLOB field using Java Serialization. + * <p>You use this by creating a subclass which defines your object class.</p> + * <pre> + * public class CustomObjectAdapter extends JavaSerializationTypeAdapter<CustomObject> { + * + * public Class<CustomObject> getJavaType() { + * return CustomObject.class; + * } + * } + * </pre> + * @param <T> + */ +public abstract class JavaSerializationTypeAdapter<T> implements DataTypeAdapter<T> { + + @Override + public final String getDataType() { + return "BLOB"; + } + + @Override + public final Object serialize(T value) { + ByteArrayOutputStream os = new ByteArrayOutputStream(); + try { + new ObjectOutputStream(os).writeObject(value); + return os.toByteArray(); + } catch (IOException e) { + throw new IciqlException(e); + } finally { + try { + os.close(); + } catch (IOException e) { + throw new IciqlException (e); + } + } + } + + @SuppressWarnings("unchecked") + @Override + public final T deserialize(Object value) { + InputStream is = null; + if (value instanceof Blob) { + Blob blob = (Blob) value; + try { + is = blob.getBinaryStream(); + } catch (SQLException e) { + throw new IciqlException(e); + } + } else if (value instanceof byte[]) { + byte [] bytes = (byte []) value; + is = new ByteArrayInputStream(bytes); + } + + try { + T object = (T) new ObjectInputStream(is).readObject(); + return object; + } catch (Exception e) { + throw new IciqlException(e); + } finally { + if (is != null) { + try { + is.close(); + } catch (IOException e) { + throw new IciqlException (e); + } + } + } + } +} diff --git a/src/main/java/com/iciql/adapter/XStreamTypeAdapter.java b/src/main/java/com/iciql/adapter/XStreamTypeAdapter.java new file mode 100644 index 0000000..3d1a9ce --- /dev/null +++ b/src/main/java/com/iciql/adapter/XStreamTypeAdapter.java @@ -0,0 +1,58 @@ +/* + * Copyright 2014 James Moger. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.iciql.adapter; + +import com.iciql.Iciql.DataTypeAdapter; +import com.thoughtworks.xstream.XStream; + +/** + * Base class for inserting/retrieving a Java Object (de)serialized as XML using XStream. + * <p>You use this by creating a subclass which defines your object class.</p> + * <pre> + * public class CustomObjectAdapter extends XStreamTypeAdapter<CustomObject> { + * + * public Class<CustomObject> getJavaType() { + * return CustomObject.class; + * } + * } + * </pre> + * @param <T> + */ +public abstract class XStreamTypeAdapter<T> implements DataTypeAdapter<T> { + + protected XStream xstream() { + return new XStream(); + } + + @Override + public String getDataType() { + return "TEXT"; + } + + @Override + public Object serialize(T value) { + return xstream().toXML(value); + } + + @Override + public T deserialize(Object value) { + String xml = value.toString(); + XStream xstream = xstream(); + T t = (T) xstream.fromXML(xml); + return t; + } +} diff --git a/src/main/java/com/iciql/adapter/postgres/GsonBTypeAdapter.java b/src/main/java/com/iciql/adapter/postgres/GsonBTypeAdapter.java new file mode 100644 index 0000000..6332742 --- /dev/null +++ b/src/main/java/com/iciql/adapter/postgres/GsonBTypeAdapter.java @@ -0,0 +1,51 @@ +/* + * Copyright 2014 James Moger. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.iciql.adapter.postgres; + +import java.sql.SQLException; + +import org.postgresql.util.PGobject; + +import com.iciql.adapter.GsonTypeAdapter; + +/** + * Postgres JSONB data type adapter maps a JSONB column to a domain object using Google GSON. + * + * @author James Moger + * + * @param <T> + */ +public abstract class GsonBTypeAdapter<T> extends GsonTypeAdapter<T> { + + @Override + public String getDataType() { + return "jsonb"; + } + + @Override + public Object serialize(T value) { + + String json = gson().toJson(value); + PGobject pg = new PGobject(); + pg.setType(getDataType()); + try { + pg.setValue(json); + } catch (SQLException e) { + // not thrown on base PGobject + } + return pg; + } +} diff --git a/src/main/java/com/iciql/adapter/postgres/GsonTypeAdapter.java b/src/main/java/com/iciql/adapter/postgres/GsonTypeAdapter.java new file mode 100644 index 0000000..64481bd --- /dev/null +++ b/src/main/java/com/iciql/adapter/postgres/GsonTypeAdapter.java @@ -0,0 +1,49 @@ +/* + * Copyright 2014 James Moger. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.iciql.adapter.postgres; + +import java.sql.SQLException; + +import org.postgresql.util.PGobject; + +/** + * Postgres JSON data type adapter maps a JSON column to a domain object using Google GSON. + * + * @author James Moger + * + * @param <T> + */ +public abstract class GsonTypeAdapter<T> extends com.iciql.adapter.GsonTypeAdapter<T> { + + @Override + public String getDataType() { + return "json"; + } + + @Override + public Object serialize(T value) { + + String json = gson().toJson(value); + PGobject pg = new PGobject(); + pg.setType(getDataType()); + try { + pg.setValue(json); + } catch (SQLException e) { + // not thrown on base PGobject + } + return pg; + } +} diff --git a/src/main/java/com/iciql/adapter/postgres/JsonStringAdapter.java b/src/main/java/com/iciql/adapter/postgres/JsonStringAdapter.java new file mode 100644 index 0000000..64ad073 --- /dev/null +++ b/src/main/java/com/iciql/adapter/postgres/JsonStringAdapter.java @@ -0,0 +1,55 @@ +/* + * Copyright 2014 James Moger. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.iciql.adapter.postgres; + +import java.sql.SQLException; + +import org.postgresql.util.PGobject; + +import com.iciql.Iciql.DataTypeAdapter; + +/** + * Handles transforming raw strings to/from the Postgres JSON data type. + */ + public class JsonStringAdapter implements DataTypeAdapter<String> { + + @Override + public String getDataType() { + return "json"; + } + + @Override + public Class<String> getJavaType() { + return String.class; + } + + @Override + public Object serialize(String value) { + PGobject pg = new PGobject(); + pg.setType(getDataType()); + try { + pg.setValue(value); + } catch (SQLException e) { + // not thrown on base PGobject + } + return pg; + } + + @Override + public String deserialize(Object value) { + return value.toString(); + } + }
\ No newline at end of file diff --git a/src/main/java/com/iciql/adapter/postgres/JsonbStringAdapter.java b/src/main/java/com/iciql/adapter/postgres/JsonbStringAdapter.java new file mode 100644 index 0000000..1619811 --- /dev/null +++ b/src/main/java/com/iciql/adapter/postgres/JsonbStringAdapter.java @@ -0,0 +1,55 @@ +/* + * Copyright 2014 James Moger. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.iciql.adapter.postgres; + +import java.sql.SQLException; + +import org.postgresql.util.PGobject; + +import com.iciql.Iciql.DataTypeAdapter; + +/** + * Handles transforming raw strings to/from the Postgres JSONB data type. + */ +public class JsonbStringAdapter implements DataTypeAdapter<String> { + + @Override + public String getDataType() { + return "jsonb"; + } + + @Override + public Class<String> getJavaType() { + return String.class; + } + + @Override + public Object serialize(String value) { + PGobject pg = new PGobject(); + pg.setType(getDataType()); + try { + pg.setValue(value); + } catch (SQLException e) { + // not thrown on base PGobject + } + return pg; + } + + @Override + public String deserialize(Object value) { + return value.toString(); + } +}
\ No newline at end of file diff --git a/src/main/java/com/iciql/adapter/postgres/XStreamTypeAdapter.java b/src/main/java/com/iciql/adapter/postgres/XStreamTypeAdapter.java new file mode 100644 index 0000000..1bf6fc2 --- /dev/null +++ b/src/main/java/com/iciql/adapter/postgres/XStreamTypeAdapter.java @@ -0,0 +1,35 @@ +/* + * Copyright 2014 James Moger. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.iciql.adapter.postgres; + + + +/** + * Postgres XML data type adapter maps an XML column to a domain object using XStream. + * + * @author James Moger + * + * @param <T> + */ +public abstract class XStreamTypeAdapter<T> extends com.iciql.adapter.XStreamTypeAdapter<T> { + + @Override + public String getDataType() { + return "xml"; + } + +} diff --git a/src/main/java/com/iciql/adapter/postgres/XmlStringAdapter.java b/src/main/java/com/iciql/adapter/postgres/XmlStringAdapter.java new file mode 100644 index 0000000..ded517e --- /dev/null +++ b/src/main/java/com/iciql/adapter/postgres/XmlStringAdapter.java @@ -0,0 +1,55 @@ +/* + * Copyright 2014 James Moger. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.iciql.adapter.postgres; + +import java.sql.SQLException; + +import org.postgresql.util.PGobject; + +import com.iciql.Iciql.DataTypeAdapter; + +/** + * Handles transforming raw strings to/from the Postgres XML data type. + */ +public class XmlStringAdapter implements DataTypeAdapter<String> { + + @Override + public String getDataType() { + return "xml"; + } + + @Override + public Class<String> getJavaType() { + return String.class; + } + + @Override + public Object serialize(String value) { + PGobject pg = new PGobject(); + pg.setType(getDataType()); + try { + pg.setValue(value); + } catch (SQLException e) { + // not thrown on base PGobject + } + return pg; + } + + @Override + public String deserialize(Object value) { + return value.toString(); + } +}
\ No newline at end of file |