OLEDB模式:
//需使用使用OleDbConnection,OleDbDataAdapter,OleDbCommandBuilder和DataSet
using System.Data;
using System.Data.OleDb;
static void Main(string[] args)
{
try
{
OleDbConnection dbConn = new OleDbConnection();
dbConn.ConnectionString = "Provider=sqloledb;Server=localhost;DATABASE=HotelDB;UID=sa;PWD=283918788;";
dbConn.Open();
OleDbDataAdapter dbAdap = new OleDbDataAdapter(); //聲明Adapter用以"連接配接"資料庫和DataSet
String sqlCmdStr = "select * from Employees";
dbAdap.SelectCommand = new OleDbCommand(sqlCmdStr, dbConn); //填充資料來源
DataSet ds = new DataSet();
dbAdap.Fill(ds,"Employees"); //填充
for (int i = 0; i < ds.Tables["Employees"].Rows.Count; i++) //檢視ds結果集中的記錄
{
Console.WriteLine(ds.Tables["Employees"].Rows[i][0].ToString()+" "+
ds.Tables["Employees"].Rows[i][1].ToString()+" "+
ds.Tables["Employees"].Rows[i][2].ToString()+" "+
ds.Tables["Employees"].Rows[i][3].ToString()+" "+
ds.Tables["Employees"].Rows[i][4].ToString()+" "+
ds.Tables["Employees"].Rows[i][5].ToString());
}
Console.WriteLine("-----------------------------------------------------");
for (int i = 0; i < ds.Tables["Employees"].Rows.Count; i++)
{
Console.WriteLine(ds.Tables["Employees"].Rows[i][0].ToString()+" "+
ds.Tables["Employees"].Rows[i][1].ToString()+" "+
ds.Tables["Employees"].Rows[i][2].ToString()+" "+
ds.Tables["Employees"].Rows[i][3].ToString()+" "+
ds.Tables["Employees"].Rows[i][4].ToString()+" "+
ds.Tables["Employees"].Rows[i][5].ToString());
}
dbConn.Close();
}
catch(Exception e)
{
Console.WriteLine(e.Message);
}
Console.WriteLine("-------------------\nRunOver");
Console.Read();
}
SQLClient模式:
//需使用SqlConnection,SqlCommand,SqlDataReader
using System.Data;
using System.Data.SqlClient;
static void Main(string[] args)
{
SqlConnection dbConn = new SqlConnection();
try
{
dbConn.ConnectionString = "Server=localhost;DATABASE=HotelDB;UID=sa;PWD=283918788;";
dbConn.Open();
SqlCommand sqlCmd = new SqlCommand();
sqlCmd.Connection = dbConn;
String sqlCmdText = "select * from Employees";
sqlCmd.CommandText = sqlCmdText;
SqlDataReader dr = sqlCmd.ExecuteReader();
Console.WriteLine("Connection OK!");
Console.WriteLine("---------------------------------------");
while (dr.Read()) //檢視ds結果集中的記錄
{
Console.WriteLine(dr.GetInt32(0) + " " + dr.GetValue(1) + " " + dr.GetValue(2));
}
Console.WriteLine("---------------------------------------");
dr.Close();
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
finally
{
if( dbConn.State == ConnectionState.Open )
dbConn.Close();
}
Console.WriteLine("Connection Close!");
Console.Read();
}