asp.net 备份和恢复数据库的方法示例

/**********************************************************************************

 *
 * 功能说明:备份和恢复sql server数据库
 * 作者: 刘功勋;
 * 版本:v0.1(c#2.0);时间:2007-1-1
 * 当使用sql server时,请引用 com组件中的,sqldmo.dll组件
 * 当使用access中,请浏览添加引用以下两个dll
 *          引用c:\program files\common files\system\ado\msadox.dll,该dll包含adox命名空间
 *          引用c:\program files\common files\system\ado\msjro.dll,该dll包含jro命名空间
 * *******************************************************************************/
using system;
using system.data;
using system.configuration;
using system.web;
using system.web.security;
using system.web.ui;
using system.web.ui.webcontrols;
using system.web.ui.webcontrols.webparts;
using system.web.ui.htmlcontrols;
using system.io;
using adox;//该命名空间包含创建access的类(方法)--解决方案 ==> 引用 ==> 添加引用 ==> 游览找到.dll
using jro;//该命名空间包含压缩access的类(方法)

namespace ec
{
    /// <summary>
    /// 数据库恢复和备份
    /// </summary>
    public class sqlbackobject
    {
        public sqlbackobject()
        {
            //
            // todo: 在此处添加构造函数逻辑
            //
        }

        #region sql数据库备份
       /// <summary>
        /// sql数据库备份
       /// </summary>
       /// <param name="serverip">sql服务器ip或(localhost)</param>
       /// <param name="loginname">数据库登录名</param>
       /// <param name="loginpass">数据库登录密码</param>
       /// <param name="dbname">数据库名</param>
       /// <param name="backpath">备份到的路径</param>
        public static void sqlback(string serverip,string loginname,string loginpass,string dbname,string backpath)
        {
            sqldmo.backup obackup = new sqldmo.backupclass();
            sqldmo.sqlserver osqlserver = new sqldmo.sqlserverclass();
            try
            {
                osqlserver.loginsecure = false;
                osqlserver.connect(serverip, loginname, loginpass);
                obackup.database = dbname;
                obackup.files = backpath;
                obackup.backupsetname = dbname;
                obackup.backupsetdescription = "数据库备份";
                obackup.initialize = true;
                obackup.sqlbackup(osqlserver);

            }
            catch (exception e)
            {
                throw new exception(e.tostring());
            }
            finally
            {
                osqlserver.disconnect();
            }
        }
        #endregion

        #region sql恢复数据库
        /// <summary>
        /// sql恢复数据库
        /// </summary>
        /// <param name="serverip">sql服务器ip或(localhost)</param>
        /// <param name="loginname">数据库登录名</param>
        /// <param name="loginpass">数据库登录密码</param>
        /// <param name="dbname">要还原的数据库名</param>
        /// <param name="backpath">数据库备份的路径</param>

        public static void sqldbrestore(string serverip,string loginname,string loginpass,string dbname,string backpath)
        {

            sqldmo.restore orestore = new sqldmo.restoreclass();
            sqldmo.sqlserver osqlserver = new sqldmo.sqlserverclass();
            try
            {
                osqlserver.loginsecure = false;
                osqlserver.connect(serverip, loginname, loginpass);
                orestore.action = sqldmo.sqldmo_restore_type.sqldmorestore_database;
                orestore.database = dbname;
                orestore.files = backpath;
                orestore.filenumber = 1;
                orestore.replacedatabase = true;
                orestore.sqlrestore(osqlserver);

            }
            catch (exception e)
            {
                throw new exception(e.tostring());
            }
            finally
            {
                osqlserver.disconnect();
            }
        }

        #endregion

        #region 根据指定的文件名称创建access数据库
        /// <summary>
        /// 根据指定的文件名称创建数据
        /// </summary>
        /// <param name="dbpath">绝对路径+文件名称</param>
        public static void createaccess(string dbpath)
        {
            if (file.exists(dbpath))//检查数据库是否已存在
            {
                throw new exception("目标数据库已存在,无法创建");
            }         
            dbpath = "provider=microsoft.jet.oledb.4.0;data source="+dbpath;
            //创建一个catalogclass对象实例
            adox.catalogclass cat = new adox.catalogclass();
            //使用catalogclass对象的create方法创建access数据库
            cat.create(dbpath);

        }
        #endregion

        #region 压缩access数据库
        /// <summary>
        /// 压缩access数据库
        /// </summary>
        /// <param name="dbpath">数据库绝对路径</param>
        public static void compactaccess(string dbpath)
        {
            if (!file.exists(dbpath))
            {
                throw new exception("目标数据库不存在,无法压缩");
            }

            //声明临时数据库名称
            string temp = datetime.now.year.tostring();
            temp += datetime.now.month.tostring();
            temp += datetime.now.day.tostring();
            temp += datetime.now.hour.tostring();
            temp += datetime.now.minute.tostring();
            temp += datetime.now.second.tostring() + ".bak";
            temp = dbpath.substring(0, dbpath.lastindexof("\\") + 1) + temp;
            //定义临时数据库的连接字符串
            string temp2 = "provider=microsoft.jet.oledb.4.0;data source="+temp;
            //定义目标数据库的连接字符串
            string dbpath2 = "provider=microsoft.jet.oledb.4.0;data source="+dbpath;
            //创建一个jetengineclass对象的实例
            jro.jetengineclass jt = new jro.jetengineclass();
            //使用jetengineclass对象的compactdatabase方法压缩修复数据库
            jt.compactdatabase(dbpath2, temp2);
            //拷贝临时数据库到目标数据库(覆盖)
            file.copy(temp, dbpath, true);
            //最后删除临时数据库
            file.delete(temp);
        }
        #endregion

        #region 备份access数据库
        /// <summary>
        /// 备份access数据库
        /// </summary>
        /// <param name="srcpath">要备份的数据库绝对路径</param>
        /// <param name="aimpath">备份到的数据库绝对路径</param>
        /// <returns></returns>
        public static void backup(string srcpath,string aimpath)
        {

            if (!file.exists(srcpath))
            {
                throw new exception("源数据库不存在,无法备份");
            }
            try
            {
                file.copy(srcpath,aimpath,true);
            }
            catch(ioexception ixp)
            {
                throw new exception(ixp.tostring());
            }

        }

        #endregion

        #region 还原access数据库
        /// <summary>
        /// 还原access数据库
        /// </summary>
        /// <param name="bakpath">备份的数据库绝对路径</param>
        /// <param name="dbpath">要还原的数据库绝对路径</param>
        public static void recoveraccess(string bakpath,string dbpath)
        {         
            if (!file.exists(bakpath))
            {
                throw new exception("备份数据库不存在,无法还原");
            }
            try
            {
                file.copy(bakpath, dbpath, true);
            }
            catch (ioexception ixp)
            {
                throw new exception(ixp.tostring());
            }      
        }      
        #endregion
    }
}