X-Git-Url: http://jaekl.net/gitweb/?a=blobdiff_plain;ds=sidebyside;f=prod%2Fnet%2Fjaekl%2Fcfb%2Fdb%2FSchema.java;h=898687ee4db5fd65112c10d6c39663b1891b4765;hb=58107a0cbb49652e7772ce80fb73d2c027590eb1;hp=b6dc6012fc6d720ded5ecae5383c7943e4558afe;hpb=5bc9bbe3fd54b9fc7aa3b92d2d37e95c41b9645a;p=cfb.git

diff --git a/prod/net/jaekl/cfb/db/Schema.java b/prod/net/jaekl/cfb/db/Schema.java
index b6dc601..898687e 100644
--- a/prod/net/jaekl/cfb/db/Schema.java
+++ b/prod/net/jaekl/cfb/db/Schema.java
@@ -16,11 +16,13 @@ public class Schema {
 	String m_name;
 	DbDriver m_driver;
 	ArrayList<Table> m_tables;
+	ArrayList<Sequence> m_sequences;
 	
 	public Schema(String name, DbDriver driver) {
 		m_name = name;
 		m_driver = driver;
 		m_tables = new ArrayList<Table>();
+		m_sequences = new ArrayList<Sequence>();
 	}
 	
 	public boolean ensureDbInitialized(Connection con) throws SQLException {
@@ -34,6 +36,26 @@ public class Schema {
 			return false;
 		}
 		
+		if (!createAllSequences(con)) { 
+			return false;
+		}
+		
+		if (!postCreationInit(con)) {
+			return false;
+		}
+		
+		return true;
+	}
+	
+	public void purge(Connection con) throws SQLException {
+		dropAllTables(con);
+		dropAllSequences(con);
+	}
+	
+	boolean postCreationInit(Connection con) throws SQLException {
+		// no-op
+		// Override this in a derived class if you need to initialize something 
+		// after the tables and sequences are created.
 		return true;
 	}
 	
@@ -73,6 +95,37 @@ public class Schema {
 		return true;
 	}
 	
+	void dropAllTables(Connection con) {
+		for (Table table : m_tables) {
+			try {
+				m_driver.dropTable(con, table);
+			}
+			catch (SQLException e) {
+				e.printStackTrace();
+			}
+		}
+	}
+	
+	boolean createAllSequences(Connection con) throws SQLException {
+		for (Sequence seq : m_sequences) {
+			if (!m_driver.createSequence(con, seq)) {
+				return false;
+			}
+		}
+		return true;
+	}
+	
+	void dropAllSequences(Connection con) {
+		for (Sequence seq : m_sequences) {
+			try {
+				m_driver.dropSequence(con, seq);
+			}
+			catch (SQLException e) {
+				e.printStackTrace();
+			}
+		}
+	}
+	
 	void addTable(Table table) {
 		m_tables.add(table);
 	}
@@ -83,10 +136,20 @@ public class Schema {
 	//   { table_name },
 	//   { column_name, type, width (-1 for default), null/not_null }
 	// }
-	void addTables(Object[][][] tables) 
+	void addTables(Table[] tables) 
 	{
-		for (Object[][] table : tables) {
-			addTable(Table.construct(table));
+		for (Table table : tables) {
+			addTable(table);
+		}
+	}
+	
+	void addSequence(Sequence seq) {
+		m_sequences.add(seq);
+	}
+	
+	void addSequences(Sequence[] sequences) {
+		for (Sequence sequence : sequences) {
+			addSequence(sequence);
 		}
-	}	
+	}
 }