#!/usr/bin/env groovy
import groovy.sql.Sql

Sql.metaClass.create_migrated_table = { table_name ->
    execute("CREATE TABLE migrated_" + table_name + " LIKE " + table_name)
}

def oriSql = Sql.newInstance('jdbc:mysql://localhost:3306/cura', 'root', 'mystery', 'com.mysql.jdbc.Driver')
oriSql.eachRow('show tables'){ row ->
    if (row[0].startsWith('migrated_')) {
        println "Deleting ${row[0]}"
        oriSql.execute("DROP TABLE " + row[0])
    }
}

def msSql = Sql.newInstance("jdbc:jtds:sqlserver://192.168.1.10:1433/CursistenManager;instance=FEIJNAX;domain=CURA", "curaadmin",
         "nankokonlwx3e", "net.sourceforge.jtds.jdbc.Driver")

oriSql.create_migrated_table('customers')
oriSql.create_migrated_table('locations')

msSql.eachRow('select * from tblRelaties') { row ->
    oriSql.execute('INSERT INTO migrated_customers (name) VALUES (?)', [row.relBedrijfsnaam])
}

msSql.close()
oriSql.close()