@Test
public void testInsert()throws Exception{
dataSet_Insert=new FlatXmlDataSet(new File("user_insert.xml"));
IDatabaseConnection conn=tester.getConnection();
try{
DatabaseOperation.INSERT.execute(conn， dataSet_Insert);
assert conn.getRowCount("users")==3;
}finally{
conn.close();
}
}
@Test
public void testUpdate()throws Exception{
IDataSet dataSet_Update=new FlatXmlDataSet(new File("user_update.xml"));
IDatabaseConnection conn=tester.getConnection();
IDataSet expect=new FlatXmlDataSet(new File("user_update_expected.xml"));
IDataSet act=tester.getConnection().createDataSet();
try{
DatabaseOperation.UPDATE.execute(conn， dataSet_Update);
System.out.println(act.getTable("users").getRowCount());
System.out.println(act.getTable("users").getValue(act.getTable("users").getRowCount()-2，"last_name"));
assert act.getTable("users").getValue(act.getTable("users").getRowCount()-2，"last_name").toString().equals("shifan");
}finally{
conn.close();
}
}
@AfterClass
public void clearDB() throws Exception{
IDatabaseConnection conn=tester.getConnection();
try{
//數(shù)據(jù)還原
DatabaseOperation.CLEAN_INSERT.execute(conn， dataSet_init);
}finally{
conn.close();
}
}
}
