|
;User ID=openlab;PassWord=open123";
queryString = "SELECT * FROM T_USER";
OracleConnection myConnection = new OracleConnection(connectionString);
OracleCommand myORACCommand = myConnection.CreateCommand();
myORACCommand.CommandText = queryString;
myConnection.Open();
OracleDataReader myDataReader = myORACCommand.ExecuteReader();
myDataReader.Read();
Console.WriteLine("email: " + myDataReader["EMAIL"]);
myDataReader.Close();
myConnection.Close();
*/
string connString = "Data Source=server1;Persist Security Info=True;User ID=s227;Password=123;Unicode=True";
string queryString = "SELECT * FROM PRODUCT ";
string _connectionString="Data Source=server1;Persist Security Info=True;User ID=s227;Password=123;Unicode=True";
string _tableName="SPJ";
string _fields = "*";
string _whercase = "";
int _pageSize = 10;
int _pageNow = 1;
string _orderField = "";
int _orderFlag = 0;
int _myRows;
int _myPageCount;
DataTable result2;
Paging newpage = new Paging();
newpage.ConnectionString = connString;
newpage.TableName = _tableName;
newpage.fenye();
//Paging newpage = new Paging(_connectionString, _tableName, _fields, _whercase, _pageSize, _pageNow, _orderField, _orderFlag, _myRows, _myPageCount, result2);
for (int i = 0; i < newpage.Result.Rows.Count; i++)
{
for (int j = 0; j < newpage.Result.Columns.Count; j++)
{
Console.Write(newpage.Result.Rows[i][j].ToString()+" ");
}
Console.WriteLine(" ");
}
newpage.PageNow = newpage.PageNow + 1;
Console.WriteLine(" ");
newpage.fenye();
for (int i = 0; i < newpage.Result.Rows.Count; i++)
{
for (int j = 0; j < newpage.Result.Columns.Count; j++)
{
Console.Write(newpage.Result.Rows[i][j].ToString() + " ");
}
Console.WriteLine(" ");
}
}
}
///
/// c#调用oracle的过程进行分页
/// author:sirc_ljp
/// date:2011.11.16
///
public class Paging
{
private string _connectionString;
private string _tableName;
private string _fields = "*";
private string _whercase = "";
private int _pageSize = 10;
private int _pageNow = 1;
private string _orderField = "";
private int _orderFlag = 0;
private int _myRows;
private int _myPageCount;
private DataTable _result;
///
/// 数据库连接字符串
///
public string ConnectionString
{
get { return _connectionString; }
set { _connectionString = value; }
}
///
/// 表名
///
public string TableName
{
get { return _tableName; }
set { _tableName = value; }
}
///
/// 查询结果显示字段
///
public string Fields
{
get { return _fields; }
set { _fields = value; }
}
///
/// 查询条件
///
public string Whercase
{
get { return _whercase; }
set { _whercase = value; }
}
///
/// 页显示记录数
///
public int PageSize
{
get { return _pageSize; }
set { _pageSize = value; }
}
///
/// 当前页
///
public int PageNow
{
get { return _pageNow; }
set { _pageNow = value; }
}
///
/// 排序字段，为空""表示不排序
///
public string OrderField
{
get { return _orderField; }
set { _orderField = value; }
}
///
/// 排序标识 0：正序 1：倒序
///
public int OrderFlag
{
get { return _orderFlag; }
set { _orderFlag = value; }
}
///
/// 总记录数
///
public int MyRows
{
get { return _myRows; }
}
///
/// 总分页
///
public int MyPageCount
{
get { return _myPageCount; }
}
///
/// 返回的记录集
///
public DataTable Result
{
get { return _result; }
}
public Paging()
{
// fenye();
}
public Paging(string connectionString, string tableName, string fields, string wherecase, int pageSize, int pageNow, string orderField, int orderFlag, out int myRows, out int myPageCount, out DataTable result)
{
_connectionString = connectionString;
_tableName = tableName;
_fields = fields;
_whercase = wherecase;
_pageSize = pageSize;
_pageNow = pageNow;
_orderField = orderField;
_orderFlag = orderFlag;
//fenye();
myRows = _myRows;
myPageCount = _myPageCount;
result = _result;
}
public void fenye()
{
OracleConnection conn = new OracleConnection(_connectionString);
conn.Open();
try
{
OracleCommand |