rspagedemo.java

里面所含源码是本人平时做程序的一些实例

import java.sql.*;
public class RsPageDemo
{
	public static void main(String args[])
	{
		if(args.length!=2)
		{
			System.out.println("参数错误");
			System.out.println("use:java RsPageDemo NoPage PageSzie");
			return;
		}
		RsPageDemo rpd=new RsPageDemo();
		String sql="select * from users";
		int intPageNo=Integer.parseInt(args[0]);
		int intPageSize=Integer.parseInt(args[1]);
		rpd.queryRecord(rpd.openDatabase(),sql,intPageNo,intPageSize);
	}
	public Connection openDatabase()
	{
		try{
			Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
		String url="jdbc:microsoft:sqlserver://localhost:1433; DatabaseName=HappyChat";
			Connection conn=DriverManager.getConnection(url,"sa","");
			return conn;
		}
		catch(Exception e)
		{
			System.out.println ("数据库连接失败!");
			return null;
		}
	}
	public void queryRecord(Connection con,String sql,int pageNo,int pageSize)
	{
		try
		{
			if(con==null)
				throw new Exception("数据库连接失败!");
			if(sql==null)
				throw new Exception("查询字符串不能为空");
			int intRowCount;//记录数
			int intPageCount;//总页数
			Statement sm=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
			ResultSet rs=sm.executeQuery(sql);
			ResultSetMetaData rsmd=rs.getMetaData();
			int intColumn=rsmd.getColumnCount();
			rs.last();
			intRowCount=rs.getRow();
			intPageCount=(intRowCount+pageSize-1)/pageSize;
			if(intPageCount>0)
			{
				rs.absolute((pageNo-1)*pageSize+1);
				int i=0;
				while(i<pageSize&&!rs.isAfterLast())
				{
					for (int j=0;j<intColumn;j++)
					{				
						String sTemp=rs.getString(j+1);
						System.out.print(sTemp+" ");
					}
					i++;
					rs.next();
					System.out.println("");
				}
			}
		}
		catch(Exception e)
		{
			System.out.println (" 数据查询错误!");
		}
	}
}