Added support for schema creation and dropping according to prefixes defined at tables level

Author: Guillaume Grussenmeyer

src/main/scala/org/squeryl/Schema.scala

@@ -175,9 +175,12 @@ class Schema(implicit val fieldMapper: FieldMapper) {
       _dbAdapter.dropTable(t)
       _dbAdapter.postDropTable(t)
     }
+
+    _dropSchemas
   }  
 
   def create = {
+    _createSchemas
     _createTables
     if(_dbAdapter.supportsForeignKeyConstraints)
       _declareForeignKeyConstraints
@@ -279,6 +282,24 @@ class Schema(implicit val fieldMapper: FieldMapper) {
     }
   }
 
+  private def schemaNames = _tables.map( _.prefix ).filter( _.isDefined ).map( _.get ).toSet[String]
+
+  private def _createSchemas = {
+    for (schemaName <- this.schemaNames ) {
+      val sw = new StatementWriter( _dbAdapter )
+      _dbAdapter.writeCreateSchema( schemaName, sw )
+      _executeDdl(sw.statement)
+    }
+  }
+
+  private def _dropSchemas = {
+    for( schemaName <- this.schemaNames ) {
+      val sw = new StatementWriter( _dbAdapter )
+      _dbAdapter.writeDropSchema( schemaName, sw )
+      _executeDdl(sw.statement)
+    }
+  }
+
   private def _createConstraintsOfCompositePKs =
     for(cpk <- _allCompositePrimaryKeys) {
       val createConstraintStmt = _dbAdapter.writeCompositePrimaryKeyConstraint(cpk._1, cpk._2)

src/main/scala/org/squeryl/internals/DatabaseAdapter.scala

@@ -180,22 +180,22 @@ trait DatabaseAdapter {
   def bigDecimalTypeDeclaration(precision:Int, scale:Int) = "decimal(" + precision + "," + scale + ")"
   def timestampTypeDeclaration = "timestamp"
   def binaryTypeDeclaration = "binary"
-  def uuidTypeDeclaration = "char(36)"
+  def uuidTypeDeclaration = "char(36)"
   def intArrayTypeDeclaration = intTypeDeclaration + "[]"
   def longArrayTypeDeclaration = longTypeDeclaration + "[]"
   def doubleArrayTypeDeclaration = doubleTypeDeclaration + "[]"
-    
-  def jdbcIntArrayCreationType = intTypeDeclaration
-  def jdbcLongArrayCreationType = longTypeDeclaration
-  def jdbcDoubleArrayCreationType = doubleTypeDeclaration
-    
-  final def arrayCreationType(ptype : Class[_]) : String = {
+    
+  def jdbcIntArrayCreationType = intTypeDeclaration
+  def jdbcLongArrayCreationType = longTypeDeclaration
+  def jdbcDoubleArrayCreationType = doubleTypeDeclaration
+    
+  final def arrayCreationType(ptype : Class[_]) : String = {
     val rv = ptype.getName() match {
       case "java.lang.Integer" => jdbcIntArrayCreationType
       case "java.lang.Double" => jdbcDoubleArrayCreationType
-      case "java.lang.Long" => jdbcLongArrayCreationType
+      case "java.lang.Long" => jdbcLongArrayCreationType
       case _ => ""
-    }
+    }
     rv
   }
 
@@ -281,8 +281,18 @@ trait DatabaseAdapter {
       )
     }
     sw.write(")")
-  }                     
-  
+  }
+
+  def writeCreateSchema(name: String, sw: StatementWriter) = {
+    sw.write("create schema ")
+    sw.write( quoteName(name) )
+  }
+
+  def writeDropSchema(name: String, sw: StatementWriter) = {
+    sw.write("drop schema ")
+    sw.write( quoteName(name ) )
+  }
+
   def convertParamsForJdbc(params: Iterable[AnyRef]) =
     for(p <- params) yield {
        p match {
@@ -821,7 +831,7 @@ trait DatabaseAdapter {
       else if(classOf[scala.Array[Double]].isAssignableFrom(c))
         doubleArrayTypeDeclaration
       else
-        Utils.throwError("unsupported type " + ar.getClass.getCanonicalName)
+        Utils.throwError("unsupported type " + ar.getClass.getCanonicalName)
 
       decl    
   }