?? oledboperator.cs
字號:
using System;
using System.Collections.Generic;
using System.Text;
using System.IO;
using System.Data;
using System.Data.OleDb;
namespace IDbAccess
{
//OLEDB的數據庫訪問類:
class OleDbAccess : IDbAccess
{
private OleDbConnection conn; //數據庫連接對象
private OleDbTransaction trans; //事務處理對象
private bool inTransaction = false; //true表示當前正處于事務中
public IDbConnection Connection
{
get
{
return this.conn;
}
}
public OleDbAccess(string strConnection)
{
this.conn = new OleDbConnection(strConnection);
}
public void Open()
{
if (conn.State != ConnectionState.Open)
{
this.conn.Open();
}
}
public void Close()
{
if (conn.State == ConnectionState.Open)
{
this.conn.Close();
}
}
public void BeginTrans()
{
trans = conn.BeginTransaction();
inTransaction = true;
}
public void CommitTrans()
{
trans.Commit();
inTransaction = false;
}
public void RollbackTrans()
{
trans.Rollback();
inTransaction = false;
}
public void ExecSQLNoDataSet(string strSql, string[] strParams, object[] strValues)
{
OleDbCommand cmd = new OleDbCommand();
cmd.Connection = this.conn;
if (inTransaction)
{
cmd.Transaction = trans;
}
if ((strParams != null) && (strParams.Length != strValues.Length))
{
throw new Exception("查詢參數和值不對應");
}
cmd.CommandText = strSql;
if (strParams != null)
{
for (int i = 0; i < strParams.Length; i++)
{
cmd.Parameters.Add(strValues[i]);
}
}
cmd.ExecuteNonQuery();
}
public void ExecSQLNoDataSet(string strSql)
{
OleDbCommand cmd = new OleDbCommand();
cmd.Connection = this.conn;
if (inTransaction)
{
cmd.Transaction = trans;
}
cmd.CommandText = strSql;
cmd.ExecuteNonQuery();
}
public DataSet ExecSQLGetDataSet(string QueryString)
{
OleDbCommand cmd = new OleDbCommand();
cmd.Connection = this.conn;
if (inTransaction)
{
cmd.Transaction = trans;
}
DataSet ds = new DataSet();
OleDbDataAdapter ad = new OleDbDataAdapter();
cmd.CommandText = QueryString;
ad.SelectCommand = cmd;
ad.Fill(ds);
return ds;
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -