using System;
using System.Data;
using System.Data.SqlClient;namespace news.common
{
/**
* -----------------
* 数据库联接 / 操作类
* ----------------
*/ public class DBClass
{
/*----全局变量定义------*/ private SqlConnection conn;
private SqlCommand comm;
public SqlDataReader dr;
public DataSet ds;
public SqlDataAdapter dad;
private string sql;
private string connStr; /* 数据库联接字符串 */
private string errInfo ="";
/*----------------------*/ public DBClass()
{
}
/* 数据库操作异常信息 只读属性 */
public string ErrInfo
{
get
{
return errInfo;
}
}
/* 要操作的Sql语句 */
public string Sql
{
get{
return sql;
}
set{
sql = value;
}
}
/* 数据库链接字符串 */
public string ConnStr
{
get
{
return connStr;
}
set
{
connStr = value;
}
}
private void connDb()
{
conn = new SqlConnection(connStr);
try
{
conn.Open();
}
catch(SqlException e)
{
for(int i=0;i<e.Errors.Count;i++)
{
errInfo += "错误序号:"+i+"\n"+
"出错信息:"+e.Errors[i].Message+"\n"+
"出错来源:"+e.Errors[i].Source+"\n"+
"程序:"+e.Errors[i].Procedure;
}
conn.Close();
}
}
/* 用于窗体绑定 */
public void dataView()
{
connDb();
dad = new SqlDataAdapter(sql,conn);
ds = new DataSet();
dad.Fill(ds);
DataView dv = new DataView(ds.Tables[0]);
}
/* 执行SQL语句,返回结果 */
public void readerData()
{
connDb();
comm = new SqlCommand(sql,conn);
dr = comm.ExecuteReader();
}
/* 执行SQL语句,不返回结果 */
public void exeSql()
{
connDb();
comm = new SqlCommand(sql,conn);
comm.ExecuteNonQuery();
}
/* 关闭链接 */
public void clear()
{
conn.Close();
}
}
}
using System.Data;
using System.Data.SqlClient;namespace news.common
{
/**
* -----------------
* 数据库联接 / 操作类
* ----------------
*/ public class DBClass
{
/*----全局变量定义------*/ private SqlConnection conn;
private SqlCommand comm;
public SqlDataReader dr;
public DataSet ds;
public SqlDataAdapter dad;
private string sql;
private string connStr; /* 数据库联接字符串 */
private string errInfo ="";
/*----------------------*/ public DBClass()
{
}
/* 数据库操作异常信息 只读属性 */
public string ErrInfo
{
get
{
return errInfo;
}
}
/* 要操作的Sql语句 */
public string Sql
{
get{
return sql;
}
set{
sql = value;
}
}
/* 数据库链接字符串 */
public string ConnStr
{
get
{
return connStr;
}
set
{
connStr = value;
}
}
private void connDb()
{
conn = new SqlConnection(connStr);
try
{
conn.Open();
}
catch(SqlException e)
{
for(int i=0;i<e.Errors.Count;i++)
{
errInfo += "错误序号:"+i+"\n"+
"出错信息:"+e.Errors[i].Message+"\n"+
"出错来源:"+e.Errors[i].Source+"\n"+
"程序:"+e.Errors[i].Procedure;
}
conn.Close();
}
}
/* 用于窗体绑定 */
public void dataView()
{
connDb();
dad = new SqlDataAdapter(sql,conn);
ds = new DataSet();
dad.Fill(ds);
DataView dv = new DataView(ds.Tables[0]);
}
/* 执行SQL语句,返回结果 */
public void readerData()
{
connDb();
comm = new SqlCommand(sql,conn);
dr = comm.ExecuteReader();
}
/* 执行SQL语句,不返回结果 */
public void exeSql()
{
connDb();
comm = new SqlCommand(sql,conn);
comm.ExecuteNonQuery();
}
/* 关闭链接 */
public void clear()
{
conn.Close();
}
}
}
SqlConnection conn = new SqlConnection(connStr);
string sqlStr = "...";
SqlCommand cmd = new SqlCommand(sqlStr, conn);
SqlDataAdapter da = new SqlDataAdapter(cmd);
.....
using System.Data.OleDb;
public static OleDbConnection createOleconn()//连接Access
{
string strConnection = "Provider=Microsoft.Jet.OleDb.4.0;";
strConnection += @"Data Source=E:\net\datagridTest\CP2SysTempDB.mdb";
// strConnection += "Data Source=";
// strConnection += Server.MapPath("CP2SysTempDB.mdb");
OleDbConnection olconn = new OleDbConnection(strConnection);
return olconn;
}
using System.Data.SqlClient;SqlConnection con=new SqlConnection("server=.;database=student;uid=sa;pwd=0421");
SqlDataAdapter sda=new SqlDataAdapter("select * from studentDetails",con);
DataSet ds=new DataSet();
sda.Fill(ds,"student");
this.DataGridView.DataSource=ds.Tables["student"];
OleDbDataAdapter sda=new OleDbDataAdapter("select * from studentDetails",con);
DataSet ds=new DataSet();
sda.Fill(ds,"student");
this.DataGrid1.DataSource=ds.Tables["student"];//如果是WebForm的话,还得加这么一句
//this.DataGrid1.DataBind();