testpagehelpersetup.java

文件上传用例,纯sql分页源码,有用的着地方请下载 试用

package org.derrick.jdbc.page;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;

import junit.extensions.TestSetup;
import junit.framework.Test;

import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import org.derrick.jdbc.ConnectionFactory;
/**
 * 
 * @author 刘冬宝Oct 26, 2006
   版权申明：所有人员均可自由修改源码并再发布，但必须保留此相关信息
 *
 */
public abstract class TestPageHelperSetup extends TestSetup {
	public static Connection conn = null;

	protected final Logger logger = LogManager.getLogger(getClass());

	protected abstract Connection getConnection();

	private void initTestData() {
		PreparedStatement pst = null;
		try {
			pst = getActiveConnection()
					.prepareStatement(
							"INSERT INTO pageDemo  (id,name,createDate)VALUES (?,?,?) ");
			for (int i = 0; i < 1000; i++) {
				pst.setInt(1, i + 1);
				pst.setString(2, String.valueOf(System.currentTimeMillis()));
				pst.setTimestamp(3, new Timestamp(System.currentTimeMillis()));
				pst.executeUpdate();
				logger.debug("insert pageDemo " + i);
			}
		} catch (SQLException e) {
			throw new RuntimeException(e);
		} finally {
			ConnectionFactory.closeStatement(pst);
		}
	}

	private Connection getActiveConnection() {
		if (conn == null)
			conn = getConnection();
		return conn;
	}

	private void clearTestData() {
		PreparedStatement pst = null;
		try {
			pst = getActiveConnection().prepareStatement(
					"delete from  pageDemo  ");
			pst.executeUpdate();
			logger.debug("delete all pageDemo data");
		} catch (SQLException e) {
			throw new RuntimeException(e);
		} finally {
			ConnectionFactory.closeStatement(pst);
		}
	}

	public TestPageHelperSetup(Test test) {
		super(test);
	}

	protected void setUp() throws Exception {
		super.setUp();
		initTestData();
	}

	protected void tearDown() throws Exception {
		clearTestData();
		ConnectionFactory.closeConnection(getActiveConnection());
		super.tearDown();
	}

}

class PageDemoOR implements DbToObject {

	public Object mapRow(ResultSet rs, int rownum) throws Exception {
		PageDemo object = new PageDemo();
		object.id = rs.getInt("id");
		object.name = rs.getString("name");
		return object;
	}

}

class PageDemo {
	int id;

	String name;
}