adding beginnings of some common abstractions

src/main/java/org/springframework/data/core/DataMapper.java

@@ -0,0 +1,29 @@
+/*
+ * Copyright 2010 the original author or authors.
+ *
+ * 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 org.springframework.data.core;
+
+/**
+ * Class used to map data to a business object.
+ *
+ * @author Thomas Risberg
+ * @since 1.0
+ */
+public interface DataMapper<S, T> {
+	
+	T map(S source);
+
+}

src/main/java/org/springframework/data/core/DataValueSource.java

@@ -0,0 +1,29 @@
+/*
+ * Copyright 2010 the original author or authors.
+ *
+ * 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 org.springframework.data.core;
+
+/**
+ * Class used to map a business object to an object providing the data value.
+ *
+ * @author Thomas Risberg
+ * @since 1.0
+ */
+public interface DataValueSource<S, T> {
+	
+	T getValue(S source);
+
+}

src/main/java/org/springframework/data/core/QueryDefinition.java

@@ -0,0 +1,5 @@
+package org.springframework.data.core;
+
+public interface QueryDefinition {
+
+}

src/main/java/org/springframework/datastore/core/AbstractDatastoreTemplate.java

@@ -0,0 +1,31 @@
+package org.springframework.datastore.core;
+
+import java.util.List;
+
+import org.springframework.data.core.DataMapper;
+import org.springframework.data.core.QueryDefinition;
+
+public abstract class AbstractDatastoreTemplate<C> {
+	
+	protected DatastoreConnectionFactory<C> datastoreConnectionFactory;
+	
+	public DatastoreConnectionFactory<C> getDatastoreConnectionFactory() {
+		return datastoreConnectionFactory;
+	}
+
+	public void setDatastoreConnectionFactory(DatastoreConnectionFactory<C> datastoreConnectionFactory) {
+		this.datastoreConnectionFactory = datastoreConnectionFactory;
+	}
+
+	public <T> T execute(DatastoreConnectionCallback<C, T> action) {
+		try {
+			return action.doInConnection(datastoreConnectionFactory.getConnection());
+		}
+		catch (Exception e) {
+			throw new UncategorizedDatastoreException("Failure executing using datastore connection", e);
+		}
+	}
+
+	public abstract <S, T> List<T> query(QueryDefinition query, DataMapper<S, T> mapper); 
+	
+}

src/main/java/org/springframework/datastore/core/DatastoreConnectionCallback.java

@@ -0,0 +1,8 @@
+package org.springframework.datastore.core;
+
+import org.springframework.dao.DataAccessException;
+
+public interface DatastoreConnectionCallback<C, T> {
+
+	T doInConnection(C con) throws DataAccessException;
+}

src/main/java/org/springframework/datastore/core/DatastoreConnectionFactory.java

@@ -0,0 +1,5 @@
+package org.springframework.datastore.core;
+
+public interface DatastoreConnectionFactory<C> {
+	C getConnection();
+}

src/main/java/org/springframework/datastore/core/UncategorizedDatastoreException.java

@@ -0,0 +1,12 @@
+package org.springframework.datastore.core;
+
+import org.springframework.dao.UncategorizedDataAccessException;
+
+public class UncategorizedDatastoreException extends
+		UncategorizedDataAccessException {
+
+	public UncategorizedDatastoreException(String msg, Throwable cause) {
+		super(msg, cause);
+	}
+
+}

src/main/java/org/springframework/datastore/serialization/SerializationStore.java

@@ -1,4 +1,4 @@
-package org.springframework.data.serialization;
+package org.springframework.datastore.serialization;
 
 import java.lang.annotation.ElementType;
 import java.lang.annotation.RetentionPolicy;