access基本操作(c#操作,远程连接,执行sql,加密,备份)

前言

 最近项目用到了access,是的就是access,工作在桌面型的小数据库应用还是会用到的,如果你确定永远不会遇到access的操作,请忽略此篇文章

1.vs配置access

  既然是数据库,就少不了增删改查。不像mssql那样access没有存储过程(但可以进行宏操作),我们一般都是写T-SQL操作。

1.1.附上access的db操作辅助类。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data;
using System.Data.OleDb;

namespace DB
{
    class OdbcDBHelper : DBHelper
    {
        /// <summary>
        /// 读取二进制字段
        /// </summary>
        /// <param name="sql">存储过程或者sql语句</param>
        /// <param name="pars">参数列表</param>
        /// <param name="cmdType"></param>
        /// <param name="comTimeout_">超时时间</param>
        /// <returns></returns>
        public override Byte[] GetBinary(string sql, IList<JHSqlParameter> pars, CommandType cmdType)
        {
            return GetBinary(sql, pars, cmdType, comTimeout);
        }
        /// <summary>
        /// 读取二进制字段
        /// </summary>
        /// <param name="sql">存储过程或者sql语句</param>
        /// <param name="pars">参数列表</param>
        /// <param name="cmdType"></param>
        /// <param name="comTimeout_">超时时间</param>
        /// <returns></returns>
        public override Byte[] GetBinary(string sql, IList<JHSqlParameter> pars, CommandType cmdType, int comTimeout_)
        {
            using (OleDbConnection SConn = new OleDbConnection(connText))
            {
                SConn.Open();
                DataSet ds = new DataSet();
                try
                {
                    OleDbCommand cmd = new OleDbCommand();
                    if (pars != null)
                    {
                        OleDbParameter sqlp = null;
                        foreach (JHSqlParameter p in pars)
                        {
                            sqlp = new OleDbParameter();
                            sqlp.ParameterName = p.ParameterName;
                            sqlp.Value = p.Value;
                            sqlp.Direction = p.Direction;
                            cmd.Parameters.Add(sqlp);
                        }
                    }
                    cmd.CommandTimeout = comTimeout;
                    cmd.CommandText = sql;
                    cmd.CommandType = cmdType;
                    cmd.Connection = SConn;

                    OleDbDataReader sdr = cmd.ExecuteReader();
                    sdr.Read();
                    Byte[] blob = null;
                    blob = new Byte[(sdr.GetBytes(0, 0, null, 0, int.MaxValue))];
                    sdr.GetBytes(0, 0, blob, 0, blob.Length);
                    sdr.Close();
                    cmd.Parameters.Clear();

                    return blob;
                }
                catch (Exception ex)
                {
                    throw new ApplicationException(ex.Message);
                }
                finally
                {
                    SConn.Close();
                }
            }
        }

        ///// <summary>
        ///// 前端获得cmd对象
        ///// </summary>
        ///// <param name="sql">存储过程的名字</param>
        ///// <returns>SqlCommand对象</returns>
        //public override OleDbCommand GetSqlCommand(string sql)
        //{
        //    return GetSqlCommand(sql, comTimeout);
        //}
        ///// <summary>
        ///// 前端获得cmd对象
        ///// </summary>
        ///// <param name="sql">存储过程的名字</param>
        ///// <param name="comTimeout">超时时间</param>
        ///// <returns>SqlCommand对象</returns>
        //public override OleDbCommand GetSqlCommand(string sql, int comTimeout_)
        //{
        //    OleDbConnection SConn = new OleDbConnection(connText);
        //    OleDbCommand cmd = new OleDbCommand();
        //    cmd.CommandTimeout = comTimeout_;
        //    cmd.CommandText = sql;
        //    cmd.CommandType = CommandType.StoredProcedure;
        //    cmd.Connection = SConn;
        //    return cmd;
        //}

        /// <summary>
        /// 执行存储过程或者sql语句
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pars"></param>
        /// <param name="cmdType"></param>
        /// <returns>受影响的行数</returns>
        public override int ExecuteNonQuery(string sql, IList<JHSqlParameter> pars, CommandType cmdType)
        {
            return ExecuteNonQuery(sql, pars, cmdType, comTimeout);
        }
        /// <summary>
        /// 执行存储过程或者sql语句
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pars"></param>
        /// <param name="cmdType"></param>
        /// <returns>受影响的行数</returns>
        public override int ExecuteNonQuery(string sql, IList<JHSqlParameter> pars, CommandType cmdType, int comTimeout_)
        {
            using (OleDbConnection SConn = new OleDbConnection(connText))
            {
                SConn.Open();
                int i = 0;
                try
                {
                    OleDbCommand cmd = new OleDbCommand();
                    if (pars != null)
                    {
                        OleDbParameter sqlp = null;
                        foreach (JHSqlParameter p in pars)
                        {
                            sqlp = new OleDbParameter();
                            sqlp.ParameterName = p.ParameterName;
                            sqlp.Value = p.Value;
                            sqlp.Direction = p.Direction;
                            if (p.Size > 0)
                            {
                                sqlp.Size = p.Size;
                            }
                            cmd.Parameters.Add(sqlp);
                        }
                    }
                    cmd.CommandTimeout = comTimeout_;
                    cmd.CommandText = sql;
                    cmd.CommandType = cmdType;
                    cmd.Connection = SConn;
                    i = cmd.ExecuteNonQuery();

                    for (int j = 0; j < cmd.Parameters.Count; j++)
                    {
                        if (cmd.Parameters[j].Direction == ParameterDirection.InputOutput || cmd.Parameters[j].Direction == ParameterDirection.Output)
                        {
                            pars[j].Value = cmd.Parameters[j].Value;
                        }
                    }
                    cmd.Parameters.Clear();
                }
                catch (Exception ex)
                {
                    throw new ApplicationException(ex.Message);
                }
                finally
                {
                    SConn.Close();
                }
                return i;
            }
        }

        /// <summary>
        /// 执行存储过程或者sql语句_事务
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pars"></param>
        /// <param name="cmdType"></param>
        /// <returns>void</returns>
        public override void ExecuteNonQuery_Tran(string[] sql, IList<JHSqlParameter>[] pars, CommandType[] cmdType)
        {
            ExecuteNonQuery_Tran(sql, pars, cmdType, comTimeout);
        }
        /// <summary>
        /// 执行存储过程或者sql语句_事务
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pars"></param>
        /// <param name="cmdType"></param>
        /// <returns>void</returns>
        public override void ExecuteNonQuery_Tran(string[] sql, IList<JHSqlParameter>[] pars, CommandType[] cmdType, int comTimeout_)
        {
            using (OleDbConnection SConn = new OleDbConnection(connText))
            {
                SConn.Open();
                OleDbTransaction myTran = SConn.BeginTransaction();
                try
                {
                    OleDbCommand cmd = new OleDbCommand();
                    cmd.Transaction = myTran;
                    cmd.Connection = SConn;
                    for (int tt = 0; tt < sql.Length; tt++)
                    {
                        if (pars[tt] != null)
                        {
                            OleDbParameter sqlp = null;
                            foreach (JHSqlParameter p in pars[tt])
                            {
                                sqlp = new OleDbParameter();
                                sqlp.ParameterName = p.ParameterName;
                                sqlp.Value = p.Value;
                                sqlp.Direction = p.Direction;
                                if (p.Size > 0)
                                {
                                    sqlp.Size = p.Size;
                                }
                                cmd.Parameters.Add(sqlp);
                            }
                        }
                        cmd.CommandTimeout = comTimeout_;
                        cmd.CommandText = sql[tt];
                        cmd.CommandType = cmdType[tt];
                        cmd.ExecuteNonQuery();
                        for (int j = 0; j < cmd.Parameters.Count; j++)
                        {
                            if (cmd.Parameters[j].Direction == ParameterDirection.InputOutput || cmd.Parameters[j].Direction == ParameterDirection.Output)
                            {
                                pars[tt][j].Value = cmd.Parameters[j].Value;
                            }
                        }
                        cmd.Parameters.Clear();
                    }
                    myTran.Commit();
                }
                catch (Exception ex)
                {
                    myTran.Rollback();
                    throw new ApplicationException(ex.Message);
                }
                finally
                {
                    SConn.Close();
                }
            }
        }

        /// <summary>
        /// 返回第一行第一列的值
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pars"></param>
        /// <param name="cmdType"></param>
        /// <returns></returns>
        public override string ExecuteScalar(string sql, IList<JHSqlParameter> pars, CommandType cmdType)
        {
            return ExecuteScalar(sql, pars, cmdType, comTimeout);
        }
        /// <summary>
        /// 返回第一行第一列的值
        /// </summary>
        /// <param name="sql">存储过程/语句</param>
        /// <param name="pars">参数列表</param>
        /// <param name="cmdType"></param>
        /// <returns></returns>
        public override string ExecuteScalar(string sql, IList<JHSqlParameter> pars, CommandType cmdType, int comTimeout_)
        {
            using (OleDbConnection SConn = new OleDbConnection(connText))
            {
                SConn.Open();
                string str = null;
                try
                {
                    OleDbCommand cmd = new OleDbCommand();
                    if (pars != null)
                    {
                        OleDbParameter sqlp = null;
                        foreach (JHSqlParameter p in pars)
                        {
                            sqlp = new OleDbParameter();
                            sqlp.ParameterName = p.ParameterName;
                            sqlp.Value = p.Value;
                            sqlp.Direction = p.Direction;
                            cmd.Parameters.Add(sqlp);
                        }
                    }
                    cmd.CommandTimeout = comTimeout_;
                    cmd.CommandText = sql;
                    cmd.CommandType = cmdType;
                    cmd.Connection = SConn;
                    object obj = cmd.ExecuteScalar();
                    str = obj == null ? "" : obj.ToString();
                    cmd.Parameters.Clear();
                }
                catch (Exception ex)
                {
                    throw new ApplicationException(ex.Message);
                }
                finally
                {
                    SConn.Close();
                }
                return str;
            }
        }

        /// <summary>
        /// 获得DataTable
        /// </summary>
        /// <param name="sql">存储过程/语句</param>
        /// <param name="pars">参数列表</param>
        /// <returns></returns>
        public override DataTable GetDataTable(string sql, IList<JHSqlParameter> pars, CommandType cmdType)
        {
            return GetDataTable(sql, pars, cmdType, comTimeout);
        }
        /// <summary>
        /// 获得DataTable
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="pars"></param>
        /// <returns></returns>
        public override DataTable GetDataTable(string sql, IList<JHSqlParameter> pars, CommandType cmdType, int comTimeout_)
        {
            using (OleDbConnection SConn = new OleDbConnection(connText))
            {
                SConn.Open();
                DataSet ds = new DataSet();
                try
                {
                    OleDbCommand cmd = new OleDbCommand();
                    if (pars != null)
                    {
                        OleDbParameter sqlp = null;
                        foreach (JHSqlParameter p in pars)
                        {
                            sqlp = new OleDbParameter();
                            sqlp.ParameterName = p.ParameterName;
                            sqlp.Value = p.Value;
                            sqlp.Direction = p.Direction;
                            cmd.Parameters.Add(sqlp);
                        }
                    }
                    cmd.CommandTimeout = comTimeout_;
                    cmd.CommandText = sql;
                    cmd.CommandType = cmdType;
                    cmd.Connection = SConn;
                    OleDbDataAdapter da = new OleDbDataAdapter(cmd);
                    da.Fill(ds);
                    cmd.Parameters.Clear();
                }
                catch (Exception ex)
                {
                    throw new ApplicationException(ex.Message);
                }
                finally
                {
                    SConn.Close();
                }
                return ds.Tables[0];
            }
        }
    }
}

1.2.以下是在我们项目中config配置

注:其实就是在db操作的时候执行上面db操作辅助类就行了。

这个类库是我们封装的db操作的类库

 access是oledb驱动进行操作的

找到这个对应的配置 这样就行了,然后写t-sql就行了,其实和mssq基本没区别

1.3.config配置地址(access2007版本):

  注:上面的配置进行字符串加密,以下是具体链接配置。

    其中Microsoft.ACE.OLEDB.12.0;是access2007及以上。Microsoft.Jet.OLEDB.4.0;是access2003。操作过access导出的应该知道这一点,不再累述。

Provider=Microsoft.ACE.OLEDB.12.0;Data Source=\\192.168.1.207\db\mydata.accdb;Jet OLEDB:database password=123456;Persist Security Info=False

2.远程连接access

  用远程链接的目的就是在团队开发的时候共用一个access文件,方便协作。额外要求不可开发人员访问服务器,所以就想到了文件共享。

2.1.局域网文件共享(还有其他方式,在这只记录我自己的操作用的)

网络----属性----更改高级共享设置

公用启动网络发现

右击文件共享

选择everyone添加

关闭防火墙。

选择更改设置

在公用下面找到关闭密码保护共享。

完成。

2.2.直接在config中进行设置就行了

Provider=Microsoft.ACE.OLEDB.12.0;Data Source=\\192.168.1.207\db\mydata.accdb;Jet OLEDB:database password=123456;Persist Security Info=False

3.执行SQL语句

  在mssql进行t-sql操作估计已经成了习惯。所以access上执行sql语句显然也必不可少。

如下:

创建-查询设计-关闭

在创建中点击创建--查询设计---关闭弹出对话框--灰色部分右击----sql语句视图

4.access进行加密

  开发好之后显然要放到客户服务器或电脑上,如果不进行加密是不是显得很不专业

如下:

已独占方式进行打开文件(这个是关键)

然后进行加密即可。

String strConn = @"Provider=Microsoft.ACE.OLEDB.12.0; Data Source=.\DB; Jet OLEDB:Database Password=123456";

5.备份数据库(本地备份和远程备份)

方法1,:安装数据库打包的时候给电脑输入文件定时备份批命令。{用户电脑如果不能现场设置,此方法可舍弃}

方法2:利用宏操作写定时任务【ps:access里面的宏操作。用vb来写】

方法3:用一个小程序去实现,也就是咱们自己写一个程序来实现方法1,打包进去即可。同时把Windows命令在电脑中创建。

ps: 1远程借助ftp,执行批命令上传即可。

         2.至于宏操作能解决很多事情,只是有时系统会把它禁用掉。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏程序员的SOD蜜

一行代码调用实现带字段选取+条件判断+排序+分页功能的增强ORM框架

问题:3行代码 PDF.NET 是一个开源的数据开发框架,它的特点是简单、轻量、快速,易上手,而且是一个注释完善的国产开发框架,受到不少朋友的欢迎,也在我们公...

2829
来自专栏分布式系统和大数据处理

在Web站点中创建和使用Rss源

Rss是将你Web站点的内容与其他人分享的标准方式。Rss代表着:Really Simple Syndication。它不过是一个标准化的XML标记,用于描述你...

722
来自专栏王磊的博客

iBatis for net 框架使用

简介:ibatis 一词来源于“internet”和“abatis”的组合,是一个由Clinton Begin在2001年发起的开放源代码项目,到后面发展的版本...

31810
来自专栏跟着阿笨一起玩NET

违反并发性: UpdateCommand影响了预期 1 条记录中的 0 条 解决办法

本文转载:http://www.cnblogs.com/litianfei/archive/2007/08/16/858866.html

3932
来自专栏跟着阿笨一起玩NET

一步一步学Linq to sql(七):并发与事务

为了看起来清晰,我已经事先把所有分类为1产品的价格和库存修改为相同值了。然后执行下面的程序:

532
来自专栏程序员与猫

使用HttpClient的优解

新工作入职不久,目前仍然还在适应环境当中,笔者不得不说看别人的源码实在是令人痛苦。所幸前些日子终于将工作流畅地看了一遍,接下来就是熟悉框架技术的阶段了。 也正是...

4008
来自专栏Golang语言社区

游戏服务器之内存数据库redis客户端应用(下)

(3)存储一个角色的基础信息(使用命令set) 存储结构: key:BASE角色id ,value 角色基础信息 int playerId = player-...

5268
来自专栏大内老A

Is this a MS EnterLib DAAB BUG or not?

开门见山,使用MS Enterprise Library的DAAB(Data Access Application Block)获取数据时抛出异常。具体场景如下...

1847
来自专栏JackieZheng

Java豆瓣电影爬虫——模拟登录的前世今生与验证码的爱恨情仇

前言 并不是所有的网站都能够敞开心扉让你看个透彻,它们总要给你出些难题让你觉得有些东西是来之不易的,往往,这也更加激发你的激情和斗志! 从《为了媳妇的一张号,...

4006
来自专栏大内老A

事件(Event),绝大多数内存泄漏(Memory Leak)的元凶[上篇]

最近这两天一直在忙着为一个项目检查内存泄漏(Memory Leak)的问题,对相关的知识进行了一下简单的学习和探索,其间也有了一些粗浅的经验积累,今天特意写一篇...

2366

扫码关注云+社区