c#网站对服务器的数据库的备份与还原

在网站上备份数据库

1.前台页面

<div>
        需要备份的文件名：<asp:TextBox ID="bfFile" runat="server" Text="shuJuKu"></asp:TextBox>
        <asp:Button ID="btnBak" runat="server" Text="备份" OnClick="btnBak_Click" />&nbsp;
        <asp:Button ID="btnReduct" runat="server" Text="恢复" OnClick="btnReduct_Click" />&nbsp;
        <asp:Button ID="btnDelete" runat="server" Text="删除备份文件" OnClick="btnDelete_Click" />&nbsp;
        <asp:Button ID="btnDown" runat="server" Text="下载备份文件" OnClick="btnDown_Click" />
</div>

2.后台代码

//删除时用到的库
[DllImport("kernel32.dll")]
public static extern IntPtr _lopen(string lpPathName, int iReadWrite);
 
[DllImport("kernel32.dll")]
public static extern bool CloseHandle(IntPtr hObject);
 
public const int OF_READWRITE = 2;
public const int OF_SHARE_DENY_NONE = 0x40;
public readonly IntPtr HFILE_ERROR = new IntPtr(-1);

protected void btnBak_Click(object sender, EventArgs e)
       {
           ///
           ///备份方法
           ///
           SqlConnection conn = new SqlConnection("Server=数据库ip地址;Database=要备份的数据库;User ID=用户名;Password=密码;");//连接数据库语句

           SqlCommand cmdBK = new SqlCommand();
           cmdBK.CommandType = CommandType.Text;
           cmdBK.Connection = conn;
           cmdBK.CommandText = @"backup database ccd to disk='"+this.bfFile.Text+".bak' with init";//数据备份语句：backup database 数据库名 to disk='保存路径dbName.bak'

           try
           {
               conn.Open();
               cmdBK.ExecuteNonQuery();
               Response.Write("<script>alert("恭喜你，数据成功恢复为所选文档的状态！");</script>");
           }
           catch (Exception ex)
           {
               Response.Write("<script>alert("" + ex.Message + "");</script>");
           }
           finally
           {
               conn.Close();
               conn.Dispose();
           }
       }

protected void btnDown_Click(object sender, EventArgs e)
        {
            
            //下载的文件和网页的是在同一服务器上

            string fileName = "aaa.bak";//客户端保存的文件名 
            string filePath = Server.MapPath("aaa.bak");//路径

            //以字符流的形式下载文件 
            FileStream fs = new FileStream(filePath, FileMode.Open);
            byte[] bytes = new byte[(int)fs.Length];
            fs.Read(bytes, 0, bytes.Length);
            fs.Close();
            Response.ContentType = "application/octet-stream";
            //通知浏览器下载文件而不是打开 
            Response.AddHeader("Content-Disposition", "attachment; filename=" + HttpUtility.UrlEncode(fileName, System.Text.Encoding.UTF8));
            Response.BinaryWrite(bytes);
            Response.Flush();
            Response.End();
        }

 

protected void btnReduct_Click(object sender, EventArgs e)
        {
        ///
           ///还原方法
           ///

            ///杀死原来所有的数据库连接进程
            SqlConnection conn = new SqlConnection();
            conn.ConnectionString = "Data Source=数据库的IP地址;Initial Catalog=master;User ID=用户名;pwd=密码";
            conn.Open();
            string sql = "use [master] SELECT spid FROM sysprocesses ,sysdatabases WHERE sysprocesses.dbid=sysdatabases.dbid AND sysdatabases.Name='要备份的数据库'";
            SqlCommand cmd1 = new SqlCommand(sql, conn);
            SqlDataReader dr;
            ArrayList list = new ArrayList();
            try
            {
                dr = cmd1.ExecuteReader();
                while (dr.Read())
                {
                    list.Add(dr.GetInt16(0));
                }
                dr.Close();
            }
            catch (SqlException eee)
            {
                Response.Write("<script>alert(""+eee.ToString()+"");</script>");
            }
            finally
            {
                conn.Close();
            }
            //MessageBox.Show(list.Count.ToString());
            for (int i = 0; i < list.Count; i++)
            {
                conn.Open();
                cmd1 = new SqlCommand(string.Format("KILL {0}", list[i].ToString()), conn);
                cmd1.ExecuteNonQuery();
                conn.Close();
                Response.Write("<script>alert("系统已经清除的数据库线程： " + list[i].ToString() + "
正在还原数据库！");
            }
            //这里一定要是master数据库，而不能是要还原的数据库，因为这样便变成了有其它进程
            //占用了数据库。
            string constr = @"Data Source=数据库的IP地址;Initial Catalog=master;User ID=用户名;pwd=密码";
            string database = "myNewDb";
            //string path = "D:\shuJuKu.bak";


            string path = "" + bfFile.Text + ".bak";

            string BACKUP = String.Format("RESTORE DATABASE {0} FROM DISK = '{1}' WITH MOVE ", database, path);//数据恢复语句：restore database 数据库名 from disk='保存路径dbName.bak' WITH MOVE 

            SqlConnection con = new SqlConnection(constr);
            con.Open();

            //string sql2 = "select name from sys.database_files";
            string sql2 = "restore filelistonly from disk='" + path + "'";
            SqlCommand cmd2 = new SqlCommand(sql2, con);
            SqlDataReader dr2 = cmd2.ExecuteReader();
            string str1 = "";
            string str2 = "";
            while(dr2.Read())
            {
                if (dr2["PhysicalName"].ToString().Contains("mdf"))
                {
                    str1 = dr2["LogicalName"].ToString();
                }
                else if (dr2["PhysicalName"].ToString().Contains("ldf"))
                {
                    str2 = dr2["LogicalName"].ToString();
                }
            }
            dr2.Close();

            BACKUP += "'"+str1+"' TO 'd:\sjk.mdf',";///------数据文件还原后存放的新位置
            BACKUP += "MOVE '"+str2+"' TO 'd:\sjk.ldf'";//----日志文件还原后存放的新位置


            //BACKUP += "'" + str1 + "' TO 'd:\shujuku.mdf',";///------数据文件还原后存放的新位置
            //BACKUP += "MOVE '" + str2 + "' TO 'd:\shujuku.ldf'";//----日志文件还原后存放的新位置
            
            SqlCommand cmd = new SqlCommand(BACKUP, con);
            
            try
            {
                cmd.ExecuteNonQuery();
                Response.Write("<script>alert("还原成功,点击退出系统！");</script>");
                //Application.Exit();
                conn.Close();
                conn.Dispose();
            }
            catch (SqlException ee)
            {

                Response.Write("<script>alert(""+ee.ToString()+"");</script>");

            }
            finally
            {
                con.Close();
            }
        }

protected void btnDelete_Click(object sender, EventArgs e)
        {

            //不能在服务器上删除，只能手动删除

        ///
           ///删除方法
           ///
       //本地的文件删除,网页和服务器在同一ip下，删除的文件路径需要完整的文件路径

            string vFileName = @"D:\aaa.bak";
            if (!File.Exists(vFileName))
            {//判断文件是否存在
                Response.Write("<script>alert("文件都不存在，你就不要拿来耍了");</script>");
                return;
            }
            IntPtr vHandle = _lopen(vFileName, OF_READWRITE | OF_SHARE_DENY_NONE);
            if (vHandle == HFILE_ERROR)
            {//判断文件是否被占用
                Response.Write("<script>alert("文件被占用！");</script>");
                return;
            }
            else
            { 
                CloseHandle(vHandle);
                Response.Write("<script>alert("没有被占用！");</script>");


                FileInfo file = new FileInfo("D:\aaa.bak");
                file.Delete();

            }
        }

我只是实现了在服务器上的备份和还原数据库，网页和数据库在同一服务器上下载文件