C#操作Access数据库类
C#操作Access数据库类
string connstring = "server=.;database=pubs;uid=sa;pwd=;pooling=true"
SqlConnection cn = new SqlConnection("Data Source=你数据库的地址;DataBase=数据库名称;Uid=数据库用户名;Pwd=数据库密码;");
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Data.OleDb;
using System.IO;
namespace AccessC
{
public class AccessC
{
///
/// 连接常量
///
private OleDbConnection Con;
///
/// SQL命令
///
private OleDbCommand Com;
///
/// 初始化一个连接实例
///
///
文件名
public AccessC(string FilePath)
{
Con = new OleDbConnection(@"Provider =Microsoft.Jet.OLEDB.4.0;Data Source ="
+ @FilePath);
Com = new OleDbCommand();
}
///
/// 返回执行所受影响的函数
///
///
///
public int ExecuteGetLines(string com)
{
try
{
Com.CommandText = com;
Com.Connection = Con;
Con.Open();
int i = 0;
i = Com.ExecuteNonQuery();
return i;
}
catch (Exception e)
{
throw new System.ArgumentException("错误", e.Message);
}
finally
{
CloseCon();
}
}
///
/// 统计特定条件的数量
///
///
///
public int ExecteCount(string com)
{
try
{
Com.CommandText = com;
Com.Connection = Con;
Con.Open();
int i = 0;
i = (int)Com.ExecuteScalar();
return i;
}
catch (Exception e)
{
throw new System.ArgumentException("错误", e.Message);
}
finally
{
CloseCon();
}
}
///
/// 返回结果的第一行第一列
///
///
///
public object ExecuteGetCol(string com)
{
try
{
Com.CommandText = com;
Com.Connection = Con;
Con.Open();
object o = null;
o = (object)Com.ExecuteScalar();
return o;
}
catch (Exception e)
{
throw new System.ArgumentException("错误", e.Message);
}
finally
{
CloseCon();
}
}
///
/// 返回一个数据集合DataTable
///
///
///
public DataTable ExecuteGetTable(string com)
{
try
{
DataTable dt = new DataTable();
Com.CommandText = com;
Com.Connection = Con;
OleDbDataAdapter dad = new OleDbDataAdapter(Com);
dad.Fill(dt);
return dt;
}
catch (Exception e)
{
throw new System.ArgumentException("错误", e.Message);
}
finally
{
CloseCon();
}
}
///
/// 关闭连接
///
public void CloseCon()
{
Com.Dispose();
Con.Close();
}
}
}
浙公网安备 33021202002483