groovy : h2database 起步

table1.groovy

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 : %sn',row.dm,row.mc);
}

sql.close();