[svn r340] WIP commit

src/com/idcanet/vasc/backends/jdbc/JdbcXpqlVascBackend.java

@@ -0,0 +1,116 @@
+/*
+ * Copyright 2004-2007 IDCA. All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without modification, are permitted provided that the
+ * following conditions are met:
+ * 
+ *    1. Redistributions of source code must retain the above copyright notice, this list of conditions and
+ *        the following disclaimer.
+ *    2. Redistributions in binary form must reproduce the above copyright notice, this list of conditions
+ *        and the following disclaimer in the documentation and/or other materials provided with the
+ *        distribution.
+ * 
+ * THIS SOFTWARE IS PROVIDED BY IDCA AND CONTRIBUTORS ``AS IS'' AND ANY EXPRESS OR IMPLIED
+ * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
+ * FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL IDCA OR
+ * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+ * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
+ * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+ * POSSIBILITY OF SUCH DAMAGE.
+ * 
+ * The views and conclusions contained in the software and documentation are those of the authors and
+ * should not be interpreted as representing official policies, either expressed or implied, of IDCA.
+ */
+
+package com.idcanet.vasc.backends.jdbc;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import com.idcanet.vasc.core.AbstractVascBackend;
+import com.idcanet.xtes.xpql.query.QueryParameterValue;
+
+/**
+ * 
+ * @author Willem Cazander
+ * @version 1.0 Sep 5, 2008
+ */
+public class JdbcXpqlVascBackend extends AbstractVascBackend  {
+
+	private JdbcConnectionProvider jdbcConnectionProvider = null;
+	
+	private com.idcanet.xtes.xpql.query.Query query = null;
+	
+	/**
+	 * @return the JdbcConnectionProvider
+	 */
+	public JdbcConnectionProvider getJdbcConnectionProvider() {
+		return jdbcConnectionProvider;
+	}
+
+	/**
+	 * @param JdbcConnectionProvider the JdbcConnectionProvider to set
+	 */
+	public void setJdbcConnectionProvider(JdbcConnectionProvider jdbcConnectionProvider) {
+		this.jdbcConnectionProvider = jdbcConnectionProvider;
+	}
+
+	/**
+	 * @see com.idcanet.vasc.core.VascBackend#execute()
+	 */
+	public List<Object> execute() throws Exception {
+		Connection c = getJdbcConnectionProvider().getJdbcConnection();
+		try {
+			PreparedStatement q = c.prepareStatement(query.toPreparedSQL(query));
+            
+            List<QueryParameterValue> values = query.getOrderQueryParameterValues();
+            int i = 0;
+            for (QueryParameterValue value:values) {
+            	q.setObject(i,value.getValue());          	
+            	i++;
+            }
+            q.execute();
+            ResultSet rs = q.getResultSet();
+            
+            List<Object> data = new ArrayList<Object>(100);
+            do {
+            	Map<String,Object> obj = new HashMap<String,Object>(10);
+            	for (i=0;i<rs.getMetaData().getColumnCount();i++) {
+            		obj.put(rs.getMetaData().getCatalogName(i), rs.getObject(i));
+            	}
+            	data.add(obj);
+            } while (rs.next());
+			return data;
+        } finally {
+            if (c!=null) {
+            	c.close();
+            }
+        }
+	}
+
+	/**
+	 * @see com.idcanet.vasc.core.VascBackend#merge(java.lang.Object)
+	 */
+	public Object merge(Object object) throws Exception {
+		return object;
+	}
+
+	/**
+	 * @see com.idcanet.vasc.core.VascBackend#persist(java.lang.Object)
+	 */
+	public void persist(Object object) throws Exception {	
+	}
+	
+	/**
+	 * @see com.idcanet.vasc.core.VascBackend#delete(java.lang.Object)
+	 */
+	public void delete(Object object) throws Exception {
+	}
+}