|
最近公司需要我们测试这边进行单元测试(代码级测试),但是不会用JUNIT,我看了从论坛上一些有关JUNIT的资料,但是还是不清楚。我们用的是JAVA开发,开发工具是JBUILDER9,所以希望各位大大帮帮忙教我一下,下面有个例子。希望各位大大能按例子讲解,讲解一下怎么单元测试,同时希望对某些关键部分加上注释。特别是suite(),tearDown()完全不知道怎么用,只知道suite()方法是用来执行测试,tearDown()是释放资源用,具体怎么用非常的不清楚。
package com.test.mbo.dao;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.io.OutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import com.test.mbo.MBOLogger;
import com.test.mbo.exception.*;
public class TranInfoDao
{
private Connection conn;
public TranInfoDao(Connection conn)
{
this.conn = conn;
}
public void update(TranInfo tranInfo)
throws SQLException, NoSuchEntityException
{
MBOLogger.info("更新对象的实例 " + tranInfo);
PreparedStatement ps = null;
ResultSet rs = null;
StringBuffer sb = new StringBuffer();
sb.append("UPDATE TABLE_TRANLOG SET ");
sb.append("REP_CODE=? ");
sb.append("WHERE TRAN_LOGRECID=?");
try {
MBOLogger.debug("Preparing statement.");
MBOLogger.debug(sb.toString());
ps = conn.prepareStatement(sb.toString());
ps.setString(1, tranInfo.getRepCode());
ps.setString(2, tranInfo.getTranNo());
if (ps.executeUpdate() != 1)
{
throw new NoSuchEntityException("没有发现相应的记录可以更新");
}
}
catch (SQLException e)
{
throw new SQLException(e.getMessage());
}
finally
{
DAOFactory.cleanup(rs, ps);
}
}
/**
* 生成对帐文件
*/
public void produceTranFile(java.util.Date lastTime, java.util.Date now, OutputStream os)
throws SQLException, IOException
{
MBOLogger.info("生成从" + lastTime + "到" + now + "的对帐文件");
PreparedStatement ps = null;
ResultSet rs = null;
TranInfo tranInfo = null;
StringBuffer sb = new StringBuffer();
sb.append("SELECT ");
sb.append("TRAN_CODE,");
sb.append("PROC_CODE,");
sb.append("MSG_SN,");
sb.append("TRAN_TIME,");
sb.append("TRAN_DATE,");
sb.append("REF_NO,");
sb.append("TERMINAL_ID,");
sb.append("TRAN_AMT,");
sb.append("REP_CODE ");
sb.append("FROM TABLE_TRANLOG ");
sb.append("WHERE SYS_DATE>? AND SYS_DATE<=? ");
try
{
ps = conn.prepareStatement(sb.toString());
ps.setTimestamp(1, new java.sql.Timestamp(lastTime.getTime()));
ps.setTimestamp(2, new java.sql.Timestamp(now.getTime()));
rs = ps.executeQuery();
int i = 0;
DataOutputStream dos = new DataOutputStream(os);
while(rs.next())
{
i++;
StringBuffer buf = new StringBuffer();
buf.append(rs.getString(1) + ";");
buf.append(rs.getString(2) + ";");
buf.append(rs.getString(3) + ";");
buf.append(rs.getString(4) + ";");
buf.append(rs.getString(5) + ";");
buf.append(rs.getString(6) + ";");
buf.append(rs.getString(7) + ";");
buf.append(rs.getString(8) + ";");
buf.append(rs.getString(9));
dos.writeBytes(buf.toString());
dos.write(0x0d);
dos.write(0x0a);
}
dos.close();
}
catch (SQLException e)
{
throw new SQLException("网络连接失败");
}
catch (IOException ioe)
{
throw ioe;
}
finally
{
DAOFactory.cleanup(rs, ps);
}
}
public TranInfo find(String tranNo)
throws FinderException, SQLException
{
MBOLogger.info("根据关键字查询: " + tranNo);
PreparedStatement ps = null;
ResultSet rs = null;
TranInfo tranInfo = null;
StringBuffer sb = new StringBuffer();
sb.append("SELECT ");
sb.append("ACCOUNT,");
sb.append("TRAN_AMT,");
sb.append("TRAN_TIME,");
sb.append("TRAN_DATE,");
sb.append("REF_NO,");
sb.append("MSG_SN,");
sb.append("TERMINAL_ID ");
sb.append("FROM TABLE_TRANLOG WHERE TRAN_LOGRECID=?");
try
{
MBOLogger.debug("Preparing statement.");
MBOLogger.debug(sb.toString());
ps = conn.prepareStatement(sb.toString());
ps.setString(1, tranNo);
rs = ps.executeQuery();
MBOLogger.debug("Executed query.");
if (rs.next()) {
tranInfo = new TranInfo();
tranInfo.setAccount(rs.getString(1));
tranInfo.setTranAmt(rs.getDouble(2));
tranInfo.setTranTime(rs.getString(3));
tranInfo.setTranDate(rs.getString(4));
tranInfo.setRefNo(rs.getString(5));
tranInfo.setMsgSn(rs.getString(6));
tranInfo.setTerminalID(rs.getString(7));
return tranInfo;
}
else
{
//throw new ObjectNotFoundException("没有找到合适的记录");
return null;
}
} catch (SQLException e) {
throw new SQLException("网络连接失败");
} finally {
DAOFactory.cleanup(rs, ps);
}
}
public void Create(TranInfo tranInfo)
throws CreateException, SQLException
{
MBOLogger.info("创建一条新的记录: " + tranInfo);
PreparedStatement ps = null;
StringBuffer str = new StringBuffer();
str.append("INSERT INTO TABLE_TRANLOG ");
str.append(" (TRAN_LOGRECID, SETTLE_DATE, TRAN_CODE, PROC_CODE, MSG_SN, ");
str.append(" TRAN_DATE, TRAN_TIME, TRAN_AMT, REF_NO, ORIG_SN, REP_CODE, ");
str.append(" MSG_SOURCE, SYSTEM_SN, DO_FLAG, ACCOUNT, TERMINAL_ID, SYS_DATE)");
str.append(" VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, sysdate)");
try
{
if (conn.isClosed())
{
throw new IllegalStateException("数据库连接已经关闭!!!");
}
MBOLogger.debug("Preparing statement.");
MBOLogger.debug(str.toString());
ps = conn.prepareStatement(str.toString());
ps.setString(1, tranInfo.getTranNo());
ps.setString(2, tranInfo.getSettleDate());
ps.setString(3, tranInfo.getTranCode());
ps.setString(4, tranInfo.getProcCode());
ps.setString(5, tranInfo.getMsgSn());
ps.setString(6, tranInfo.getTranDate());
ps.setString(7, tranInfo.getTranTime());
ps.setDouble(8, tranInfo.getTranAmt());
ps.setString(9, tranInfo.getRefNo());
ps.setString(10, tranInfo.getOrigNo());
ps.setString(11, tranInfo.getRepCode());
ps.setString(12, tranInfo.getMsgSource());
ps.setString(13, tranInfo.getSystemSn());
ps.setString(14, tranInfo.getDoFlag());
ps.setString(15, tranInfo.getAccount());
ps.setString(16, tranInfo.getTerminalID());
if (ps.executeUpdate() != 1)
{
throw new CreateException("数据库有相同的记录");
}
}
catch(SQLException sqle)
{
throw new SQLException(sqle.getMessage());
}
finally
{
DAOFactory.cleanup(null, ps);
}
测试代码(总是不能编译)
package com.test.mbo;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.io.OutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import junit.framework.*;
import com.test.mbo.dao.TranInfoDao;
import com.test.mbo.dao.TranInfo;
import java.sql.Statement;
import java.util.Properties;
import java.sql.DriverManager;
import com.test.mbo.exception.FinderException;
/**
* <p>Title: test</p>
* <p>Description: test</p>
* <p>Copyright: Copyright (c) test 2004</p>
* <p>Company: test</p>
* @author not attributable
* @version 1.0
*/
public class testTranlnfoDao
extends TestCase {
private String data;
private TranInfoDao testinfodao;
private TranInfo testinfo;
private Connection testconn = null;
private static Test suite;
public testTranlnfoDao(String name) {
super(name);
}
public static Test suite()
{
TestSuite suite= new TestSuite();
suite.addTest(runTest());
return suite;
}
protected void runTest() throws FinderException, SQLException {
TestUpdate();
}
protected void setup();
{
testinfo = new com.test.mbo.dao.TranInfo();
testinfodao = new com.test.mbo.dao.TranInfoDao(testconn);
}
public static Connection getConnection() throws SQLException {
String url ="jdbc.url";
String username = "jdbc.username";
String password ="jdbc.password";
return DriverManager.getConnection(url, username, password);
}
public void TestUpdate() throws SQLException, FinderException
{
Connection testcoon = getConnection();
testinfo.setRepCode("test1");
testinfo.setTranNo("46");
testinfodao.update(testinfo);
TranInfo testinfoResult = null;
testinfoResult = testinfodao.find("46");
assertEquals("test1", testinfoResult.getRefNo());
if (testinfoResult == null);
throw new SQLException();
}
public void testtearDown() throws SQLException {
String datacommand = "DELETE FORM TABLE_TRANLOG" +
"WHERE TRAN_LOGRECID=(test1)";
Statement datastat = testconn.createStatement();
datastat.executeUpdate(datacommand);
testconn.close();
}
} |
|