dbclass.cs

数据库操作接口类

using System;
using System.Data;
using System.Configuration;
using System.Data.OleDb;
using System.IO;
using System.Runtime.InteropServices;

namespace UpdateProduce
{



    /// <summary>
    /// DBClass 的摘要说明
    /// </summary>
    public class DBClass
    {
        public DBClass()
        {
            //
            // TODO: 在此处添加构造函数逻辑
            //
        }
        private OleDbConnection conn;

        #region 数据库连接

        /// <summary>
        ///获得数据库连接
        /// </summary>
        /// <returns>SqlConnection对象</returns>
        public OleDbConnection GetConn()
        {
            conn = new OleDbConnection("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=d:/3d/data.mdb;" );
            return conn;

        }
        #endregion

        #region 数据集
        /// <summary>
        /// 数据集
        /// </summary>
        /// <param name="mysql">Sql语句</param>
        /// <param name="name">表名称</param>
        /// <param name="option_flag">配置标识符</param>
        /// <returns></returns>
        public DataSet MyDBSet(string mysql, string name)
        {
            using (OleDbConnection con = this.GetConn())
            {
                try
                {
                    con.Open();
                    OleDbDataAdapter da = new OleDbDataAdapter(mysql, con);
                    DataSet ds = new DataSet();
                    da.Fill(ds, name);
                    return (ds);
                }
                catch
                {
                    return (null);
                }
            }
        }

        #endregion

        #region 删除数据
        /// <summary>
        /// 删除数据
        /// </summary>
        /// <param name="tablename">表名</param>
        /// <param name="term">条件</param>
        /// <returns></returns>
        public bool delete(string tablename, string term)
        {
            string sql = "delete " + tablename + " where " + term;
            using (OleDbConnection con = this.GetConn())
            {
                OleDbCommand com = new OleDbCommand(sql, con);
                try
                {
                    con.Open();
                    com.ExecuteNonQuery();
                    com.Connection.Close();
                    return true;
                }
                catch
                {
                    com.Connection.Close();
                    return false;
                }
            }
        }
        #endregion
    }

}