groovy : h2database 起步

import groovy.sql.Sql;

def db = [
url:'jdbc:h2:~/test',
user:'sa', password:'',
driver:'org.h2.Driver'
];
// 创建数据库连接
Sql sql = Sql.newInstance(db.url, db.user, db.password, db.driver);

sql.execute("DROP TABLE IF EXISTS jjmc");
// 创建数据库表
sql.execute("""
CREATE TABLE jjmc (
dm char(6) NOT NULL,
mc varchar(60) NOT NULL,
PRIMARY KEY  (dm)
)
""");

// 插入数据
def filename = args[0];
def alist =[];
def rs =[];
String dm;
new File(filename).eachLine{ line ->
alist = line.split(',');
n = alist.size();
if (n==2){
dm = alist[0];
rs=sql.firstRow('SELECT 1 FROM jjmc where dm=?',[dm]); // 查询第一行数据
if (rs== null){
sql.execute('INSERT INTO jjmc (dm,mc) values(?,?)', alist);
println(" Insert into "+dm);
}
}
}
// 使用DataSet来处理数据
def jjmc = sql.dataSet('jjmc');
def rows = jjmc.rows();
rows.each { row ->
printf(' %s : %s\n', row.dm, row.mc);
}

sql.close();