Add schema definition

build.sbt

@@ -9,6 +9,8 @@ scalaVersion := "2.11.8"
 libraryDependencies ++= Seq(
   "com.github.jsqlparser" % "jsqlparser" % "0.9.6",
   "org.scalamacros" %% "resetallattrs"  % "1.0.0",
+  "com.fasterxml.jackson.module" %% "jackson-module-scala"  % "2.7.2",
+  "com.github.pathikrit" %% "better-files" % "2.15.0",
   "org.scala-lang" % "scala-reflect"  % scalaVersion.value,
   "org.scala-lang" % "scala-compiler" % scalaVersion.value % "provided",
   "org.scalatest" %% "scalatest" % "2.2.1" % "test"

schema.json

@@ -0,0 +1,37 @@
+{
+  "tables":[
+    {
+      "name": "USER",
+      "columns": [
+        {
+          "name": "USER_ID"
+        },
+        {
+          "name": "USER_NAME"
+        }
+      ]
+    },
+    {
+      "name": "COMPANY",
+      "columns": [
+        {
+          "name": "COMPANY_ID"
+        },
+        {
+          "name": "COMPANY_NAME"
+        }
+      ]
+    },
+    {
+      "name": "DEPT",
+      "columns": [
+        {
+          "name": "DEPT_ID"
+        },
+        {
+          "name": "DEPT_NAME"
+        }
+      ]
+    }
+  ]
+}

src/main/scala/com/github/takezoe/scala/jdbc/package.scala

@@ -1,5 +1,7 @@
 package com.github.takezoe.scala
 
+import com.fasterxml.jackson.databind.{DeserializationFeature, ObjectMapper}
+import com.fasterxml.jackson.module.scala.DefaultScalaModule
 import com.github.takezoe.scala.jdbc.SqlTemplate
 import net.sf.jsqlparser.JSQLParserException
 import net.sf.jsqlparser.parser.CCJSqlParserUtil
@@ -9,6 +11,10 @@ import scala.language.experimental.macros
 import scala.reflect.macros.blackbox.Context
 import com.github.takezoe.scala.jdbc.validation._
 
+import scala.reflect.ClassTag
+import better.files._
+import java.io.{File => JFile}
+
 package object jdbc {
 
   /**
@@ -34,6 +40,11 @@ package object jdbc {
 
 object Macros {
 
+  private val mapper = new ObjectMapper()
+  mapper.enable(DeserializationFeature.UNWRAP_SINGLE_VALUE_ARRAYS)
+  mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
+  mapper.registerModule(DefaultScalaModule)
+
   def sqlMacro(c: Context)(sql: c.Expr[String]): c.Expr[com.github.takezoe.scala.jdbc.SqlTemplate] = {
     import c.universe._
     sql.tree match {
@@ -58,6 +69,14 @@ object Macros {
   }
 
   private def validateSql(sql: String, c: Context): Unit = {
+    val file = File("schema.json")
+    val schema = if(file.exists){
+      val json = file.contentAsString
+      val schema = mapper.readValue(json, classOf[SchemaDef])
+      schema.tables.map { t => t.name -> t }.toMap
+    } else {
+      Map.empty
+    }
     try {
       val parse = CCJSqlParserUtil.parse(sql)
       parse.accept(new StatementVisitorAdapter {

src/main/scala/com/github/takezoe/scala/jdbc/validation/SchemaDef.scala

@@ -0,0 +1,7 @@
+package com.github.takezoe.scala.jdbc.validation
+
+case class SchemaDef(tables: Seq[TableDef])
+
+case class TableDef(name:String, columns: Seq[ColumnDef])
+
+case class ColumnDef(name: String)