X-Git-Url: http://jaekl.net/gitweb/?p=cfb.git;a=blobdiff_plain;f=prod%2Fnet%2Fjaekl%2Fcfb%2Fdb%2Fdriver%2FDbDriver.java;h=b8d1ee6bf5f67935a882d62d57667a82cd81a3b6;hp=bbe38f8cc0d9f23c4b3a24430bd747c1027a1354;hb=01f0bef1b13c6b9f5b370372d36ad4d6149ff2c3;hpb=f2bacf605408989ecb4faa7ff84ed5c72dd26c2b

diff --git a/prod/net/jaekl/cfb/db/driver/DbDriver.java b/prod/net/jaekl/cfb/db/driver/DbDriver.java
index bbe38f8..b8d1ee6 100644
--- a/prod/net/jaekl/cfb/db/driver/DbDriver.java
+++ b/prod/net/jaekl/cfb/db/driver/DbDriver.java
@@ -31,6 +31,8 @@ public abstract class DbDriver {
 	
 	public abstract Connection connect(String host, int port, String dbName, String user, String pass) throws SQLException;
 	
+	public abstract long nextVal(Connection con, Sequence seq) throws SQLException;
+	
 	public boolean createTable(Connection con, Table table) throws SQLException 
 	{
 		String sql = createTableSql(table);
@@ -183,22 +185,6 @@ public abstract class DbDriver {
 		return count;
 	}
 	
-	public long nextVal(Connection con, Sequence seq) throws SQLException
-	{
-		String sql = nextValSql(seq);
-		
-		try (PreparedStatement ps = con.prepareStatement(sql)) 
-		{
-			try (ResultSet rs = ps.executeQuery()) {
-				if (rs.next()) {
-					return rs.getLong(1);
-				}
-			}
-		}
-		
-		throw new SQLException("No value returned for sequence:  " + sql);
-	}
-	
 	int checkFlushBatch(PreparedStatement ps, int pendingValues, boolean forceFlush) throws SQLException
  	{
 		int count = 0;
@@ -383,8 +369,6 @@ public abstract class DbDriver {
 		return "DROP SEQUENCE " + seq.getName();
 	}
 	
-	abstract protected String nextValSql(Sequence seq);
-	
 	boolean isValidInsert(Table table, Object[][] values)
 	{
 		if (null == table) return false;
@@ -401,4 +385,15 @@ public abstract class DbDriver {
 		
 		return true;
 	}
+	
+	int executeUpdate(Connection con, String sql) throws SQLException
+	{
+		try (PreparedStatement ps = con.prepareStatement(sql))
+		{
+			return ps.executeUpdate();
+		}
+		catch (SQLException exc) {
+			throw new SQLException("Failed to executeUpdate:  " + sql, exc);
+		}
+	}
 }