10 files changed, 419 insertions, 104 deletions

diff --git a/src/main/java/com/iciql/SQLDialectPostgreSQL.java b/src/main/java/com/iciql/SQLDialectPostgreSQL.java
index f10017c..6998c24 100644
--- a/src/main/java/com/iciql/SQLDialectPostgreSQL.java
+++ b/src/main/java/com/iciql/SQLDialectPostgreSQL.java
@@ -16,11 +16,6 @@
 

 package com.iciql;

 

-import java.sql.SQLException;

-

-import org.postgresql.util.PGobject;

-

-import com.iciql.Iciql.DataTypeAdapter;

 import com.iciql.TableDefinition.IndexDefinition;

 import com.iciql.util.StatementBuilder;

 

@@ -106,102 +101,4 @@ public class SQLDialectPostgreSQL extends SQLDialectDefault {
 		stat.setSQL(buff.toString().trim());

 	}

 

-	/**

-	 * 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();

-		}

-	}

-

-	/**

-	 * 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();

-		}

-	}

-

-	/**

-	 * 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
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&lt;CustomObject&gt; {
+ *
+ *    public Class&lt;CustomObject&gt; 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/JavaSerializationTypeAdapter.java b/src/main/java/com/iciql/adapter/JavaSerializationTypeAdapter.java
index e38e0f8..c475817 100644
--- a/src/main/java/com/iciql/JavaSerializationTypeAdapter.java
+++ b/src/main/java/com/iciql/adapter/JavaSerializationTypeAdapter.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package com.iciql;
+package com.iciql.adapter;
 
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
@@ -25,6 +25,8 @@ 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;
 
 /**
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&lt;CustomObject&gt; {
+ *
+ *    public Class&lt;CustomObject&gt; 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