dbunit初步1

1. 加包dbunit-2.2.jar，数据库驱动

2. 数据库表

+----------+-------------+------+-----+---------+-------+
| Field    | Type        | Null | Key | Default | Extra |
+----------+-------------+------+-----+---------+-------+
| id       | int(11)     | NO   | PRI |         |       |
| name     | varchar(10) | YES  |     | NULL    |       |
| password | varchar(20) | YES  |     | NULL    |       |
+----------+-------------+------+-----+---------+-------+

 

3. 以前的业务操作代码（被测试的代码）

public class PersonDaoImpl implements PersonDao {
	public Person find(Integer id) throws SQLException, Exception {
		// TODO Auto-generated method stub
		Statement stat = null;
		ResultSet rs = null;
		Person person = null;
		try {
			stat = JDBCUtil.getConnection().createStatement();
			String sql = "select * from dbunit where id="+id;
			rs = stat.executeQuery(sql);
			while(rs.next()){
				person = new Person();
				person.setId(id);
				person.setName(rs.getString("name"));
				person.setPassword(rs.getString("password"));
			}
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			throw e;
		}finally{
			JDBCUtil.close(null, stat, rs);
		}
		
		return person;
	}

  

public class JDBCUtil {
	private static String driver = "com.mysql.jdbc.Driver";
	private static String name = "root";
	private static String password = "hejie";
	private static String url = "jdbc:mysql://127.0.0.1:3306/hejietest";
	
	public static Connection getConnection()throws Exception{
		Class.forName(driver);
		Connection con = DriverManager.getConnection(url,name,password);
		return con;
	}
	public static void close(Connection conn,Statement stat,ResultSet rs)throws Exception{
		if(conn!=null)conn.close();
		if(stat!=null)stat.close();
		if(rs!=null)rs.close();
	}
}

 

4. 预定义数据库数据  配置文件 dbtable.xml

<?xml version="1.0" encoding="UTF-8"?>
<dataset>
	<dbunit id="1" name="Mandy" password="Smith" />
	<dbunit id="2" name="Mandy" password="Smith" />
</dataset> 

 5. 测试代码

public class DBTest extends DatabaseTestCase {
	
	@Override
	protected IDatabaseConnection getConnection() throws Exception {
		DatabaseConnection conn = new DatabaseConnection(JDBCUtil.getConnection());
		//获得数据库连接
		return conn;
	}

	@Override
	protected IDataSet getDataSet() throws Exception {
		FlatXmlDataSet fxds = new FlatXmlDataSet(getClass().getResourceAsStream("FlatXmlSelectOwnerTest.xml"));
		return fxds ;//从文件中读出初始值为什么。
	}
	
	public void testFind(){//测试方法
		try {
			PersonDao pd = new PersonDaoImpl();
			Person person = pd.find(1);
			
//			assertEquals("string11",person.getName());
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

 

 

   补充：DatabaseOperation.CLEAN_INSERT.execute(getConnection(), fxds);

            在getDataSet返回前加上上面的代码，表示一种操作方式，已上市查处已有的在写入。