C#之Asp.net安装包的创建,打包数据库

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Node.js›Node.js教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

[RunInstaller(true)]
    public partial class JSWyglInstaller : Installer
    {
        public JSWyglInstaller()
        {

            InitializeComponent();
        }

        #region 程序代码

        /// <summary>
        /// 数据库的操作
        /// </summary>
        #region 数据库的操作属性集合
        private System.Data.SqlClient.SqlConnection sqlConn;

private System.Data.SqlClient.SqlCommand Command;

private System.Data.SqlClient.SqlTransaction Trans;

private string DBName;

private string ServerName;

private string AdminName;

        private string AdminPwd;
        ///dbname=[DBNAME] /server=[DBSERVERNAME] /user=[USERNAME] /pwd=PASSWORD] /iis=[IISSERVER] /port=[PORT] /targetdir="[TARGETDIR]\"
        #endregion
        /// <summary>
        ///IIS的操作
        /// </summary>
        #region IIS操作属性
        private string iis;

private string port;

private string dir;

public static string VirDirSchemaName = "IIsWebVirtualDir";

private string _target;

private DirectoryEntry _iisServer;

private ManagementScope _scope;

private ConnectionOptions _connection;

#endregion

//连接数据库服务器到方法：
#region ConnectDatabase 连接数据库

        private bool ConnectDatabase()
        {
            if (Command.Connection.State != ConnectionState.Open)
            {
                try
                {
                    Command.Connection.Open();
                }

                catch(Exception e)
                {
                   MessageBox.Show("打开数据库失败:"+e.Message);
                   return false;
                }

            }
            return true;
        }
        /// <summary>
        /// 开启事物
        /// </summary>
        private void BeginTrans()
        {
            if (Trans == null)
                Trans = sqlConn.BeginTransaction();
            if(Command.Transaction==null)
            Command.Transaction = Trans;
        }
        /// <summary>
        /// 提交事物
        /// </summary>
        private void CommitTrans()
        {
            if (Trans != null)
                Trans.Commit();

        }

        private void RollBack()
        {
            if (Trans != null)
                Trans.Rollback();
        }

#endregion

       //如果不能正确连接数据库服务器，请检查你的连接字符串，或者将连接字符串写入文件查看
       //读取SQL文件的方法：
       #region GetSql 从文件中读取SQL，在读取包含SQL脚本的文件时需要用到，参考自MSDN

private string GetSql(string Name)
{

                try
                {
                    //MessageBox.Show("GetSql"+Name);
                    Assembly Asm = Assembly.GetExecutingAssembly();

Stream strm = Asm.GetManifestResourceStream(Asm.GetName().Name + "." Name);

StreamReader reader = new StreamReader(strm);

                    return reader.ReadToEnd();
                }
                catch (Exception getException)
                {
                    MessageBox.Show("读取文件错误：" + getException.Message);
                    return string.Empty;
                    //throw new ApplicationException("读取文件错误："+getException.Message);
                }
            }

#endregion

//可以将此需要执行的SQL脚本放在此文本中
//执行SQL语句的方法：

#region ExecuteSql 执行SQL语句，参考自MSDN

        private void ExecuteSql(string DataBaseName, string sqlstring)
        {
            //MessageBox.Show("ExecuteSql:DataBaseName"+DataBaseName +"-SqlString:"+sqlstring);
            Command = new System.Data.SqlClient.SqlCommand(sqlstring, sqlConn);
            if (ConnectDatabase())
            {
                try
                {
                    Command.Connection.ChangeDatabase(DataBaseName);
                    Command.ExecuteNonQuery();
                    //MessageBox.Show("ChangeDataBaseSuccess");

                }
                finally
                {
                    Command.Connection.Close();
                }
            }
        }

        private void ExecuteSqlForTrans(string DataBaseName, string sqlstring)
        {
            //MessageBox.Show("ExecuteSql:DataBaseName"+DataBaseName +"-SqlString:"+sqlstring);
            if(Command==null)
            Command = new System.Data.SqlClient.SqlCommand(sqlstring, sqlConn);
            if (ConnectDatabase())
            {
                try
                {
                    BeginTrans();
                    Command.Connection.ChangeDatabase(DataBaseName);
                    Command.ExecuteNonQuery();
                    //MessageBox.Show("ChangeDataBaseSuccess");

                }
                catch(Exception ex)
                {
                    if (Trans != null)
                        Trans.Rollback();
                    Command.Connection.Close();
                    //throw new Exception("创建数据库 [" + DBName + "] 错误:" + ex.Message);
                    MessageBox.Show("创建数据库 [" + DBName + "] 错误:" + ex.Message);
                }
            }
        }

#endregion

//创建数据库及数据库表：
#region CreateDBAndTable 创建数据库及数据库表，参考自MSDN

        protected bool CreateDBAndTable(string DBName)
        {
            bool Restult = false;

            try
            {
                //MessageBox.Show("CreateDBAndTable");
                if (string.IsNullOrEmpty(DBName))
                    return false;
                ExecuteSqlForTrans("master", "USE MASTER IF EXISTS (SELECT NAME FROM SYSDATABASES WHERE NAME='" + DBName + "') DROP DATABASE " + DBName);
                ExecuteSqlForTrans("master", "CREATE DATABASE " + DBName);
                ExecuteSqlForTrans(DBName, GetSql("DBSQL.txt"));
                CommitTrans();
                Restult = true;
            }

            catch (Exception ex)
            {
                MessageBox.Show("CreateDBAndTable"+ex.Message);
                //throw new Exception("创建数据库 [" + DBName + "] 错误:" + ex.Message);
            }
            finally
            {
                if(Command!=null)
                Command.Connection.Close();
            }

return Restult;

}

#endregion

//从备份文件恢复数据库及数据库表
#region RestoreDB 从备份文件恢复数据库及数据库表

        ///
        /// 从备份文件恢复数据库及数据库表
        ///
        ///数据库名
        ///配件中数据库脚本资源的名称
        ///

        protected bool RestoreDB(string DBName)
        {
           string dir = this.Context.Parameters["targetdir"];

//MessageBox.Show("DBDir:" + dir);

dir += @"DBInit\";

bool Restult = false;

string MSQL = "RESTORE DATABASE " + DBName +

" FROM DISK = N'" + dir + @"wygl.bak' " +

" WITH MOVE 'TXFee_Data' TO N'" + @"c:\" + DBName + ".mdf', " +

" MOVE 'TXFee_log' TO N'" + @"c:\" + DBName + ".ldf' ";

try
{

                ExecuteSql("master", "USE MASTER IF EXISTS (SELECT NAME FROM SYSDATABASES WHERE NAME='" + DBName + "') DROP DATABASE " + DBName);
                ExecuteSql("master", MSQL);
                //CommitTrans();
                Restult = true;

            }
            catch(Exception ex)
            {
                MessageBox.Show("创建数据库 [" + DBName + "] 错误:" + ex.Message);
                //throw new Exception("创建数据库 [" + DBName + "] 错误:" + ex.Message);
            }
            finally
            {

                if (Command != null)
                    Command.Connection.Close();
                #region 作废
                // 删除备份文件
                //try
                //{

// File.Delete(dir + @"wygl.bak");

                //}
                //catch
                //{

//}
#endregion

}
return Restult;

}

#endregion

        //这里可以到注册表读取SQL Server的安装路径，把恢复后的数据库文件放到data目录地下。
        //在本例中，只是实现了恢复，并未进行标准的操作。其中Test和Test_log时备份时数据库的文件信息。
        //如果想要从备份文件中恢复，请把文件包含到项目里并且设置和DBSQL.txt一样，嵌入到程序里。最后执行删除。
        //不过我想应该有办法不把文件先安装到目标机器上，而是有方法想读取DBSQL.txt文件一样，直接恢复数据库，不过确实没想到办法，失败！
        //网站安装好后，需要设置web.config文件，这里只涉及到连接字符串到设置，其他的可以同理修改。

#region WriteWebConfig 修改web.config的连接数据库的字符串

        private bool WriteWebConfig()
        {

            System.IO.FileInfo FileInfo = new System.IO.FileInfo(this.Context.Parameters["targetdir"] + "/web.config");

if (!FileInfo.Exists)
{

throw new InstallException("未找到Web.Config文件 :" + this.Context.Parameters["targetdir"] + "/web.config");

}
System.Xml.XmlDocument xmlDocument = new System.Xml.XmlDocument();

            xmlDocument.Load(FileInfo.FullName);

            bool FoundIt = false,FondReportServer=false;

            foreach (System.Xml.XmlNode Node in xmlDocument["configuration"]["appSettings"])
            {
                if (Node.Name == "add")
                {
                    //根据安装设置连接字符串
                    //if (Node.Attributes.GetNamedItem("key").Value == "ConnectionString")
                    //{

                    //    Node.Attributes.GetNamedItem("value").Value = String.Format("Persist Security Info=False;Data Source={0};database={1};User ID={2};Password={3};Packet Size=4096;Pooling=true;Max Pool Size=100;Min Pool Size=1", ServerName, DBName, AdminName, AdminPwd);
                    //    FoundIt = true;
                    //}
                    //根据安装设置连接字符串
                    if (Node.Attributes.GetNamedItem("key").Value == "SqlConnectionString")
                    {

                        Node.Attributes.GetNamedItem("value").Value = String.Format("Persist Security Info=False;Data Source={0};database={1};User ID={2};Password={3};Packet Size=4096;Pooling=true;Max Pool Size=100;Min Pool Size=1", ServerName, DBName, AdminName, AdminPwd);
                        FoundIt = true;
                    }
                    if (Node.Attributes.GetNamedItem("key").Value == "SqlConnectionADO")
                    {

                        Node.Attributes.GetNamedItem("value").Value = String.Format("Provider=SQLOLEDB.1;Password={3};Persist Security Info=False;User ID={2};Initial Catalog={1};Data Source={0}", ServerName, DBName, AdminName, AdminPwd);
                        FoundIt = true;
                    }
                    //根据安装设置连接字符串
                    if (Node.Attributes.GetNamedItem("key").Value == @"auV8CdDyCk/67slOZw5fh1KU7XuAjzSUq7ZCaBKfXsgHpdZ7RgCJHL0TWqbjkpIG")
                    {
                        string str= String.Format("Persist Security Info=False;Data Source={0};database={1};User ID={2};Password={3};Packet Size=4096;Pooling=true;Max Pool Size=100;Min Pool Size=1", ServerName, DBName, AdminName, AdminPwd);
                        Node.Attributes.GetNamedItem("value").Value = WYDAL.FangChan.StringUtils.CryptographyUtility(str);

                        FoundIt = true;
                    }
                    if (Node.Attributes.GetNamedItem("key").Value == "WebReportServer")
                    {
                        string [] dir=this.Context.Parameters["targetdir"].ToString().TrimEnd('\\').Split('\\');
                        //string dirRootString = this.Context.Parameters["targetdir"].ToString();
                        string dirRootName=string.Empty;
                        if(dir!=null && dir.Length>0)
                        {
                            dirRootName=dir[dir.Length-1];
                        }
                        //Node.Attributes.GetNamedItem("value").Value = String.Format("http://{0}/{1}/ReprotServer/YaWebReportService.asmx?WSDL",this.Context.Parameters["iis"] ,dirRootName );
                        Node.Attributes.GetNamedItem("value").Value = String.Format("http://{0}/WebReportServer/YaWebReportService.asmx?WSDL", this.Context.Parameters["iis"]);
                       // MessageBox.Show(this.Context.Parameters["targetdir"]);
                        FondReportServer = true;
                    }

                }
            }
            if (!FoundIt )
            {
                throw new InstallException("查找配置文件的数据库服务信息出错!");
            }

            if( !FondReportServer)
            {
                 throw new InstallException("查找配置文件的报表服务器出错!");
            }
            xmlDocument.Save(FileInfo.FullName);

return FoundIt;

        }
        /// <summary>
        /// 从WEBCONFIG 中获取数据库连接字符串
        /// </summary>
        /// <returns></returns>
        private string GetDBNameFromWebConfig()
        {

//MessageBox.Show("webconfig");
System.IO.FileInfo FileInfo = new System.IO.FileInfo(this.Context.Parameters["targetdir"] + "/web.config");

            if (!FileInfo.Exists)
            {
                throw new InstallException("Missing config file :" + this.Context.Parameters["targetdir"] + "/web.config");

}
System.Xml.XmlDocument xmlDocument = new System.Xml.XmlDocument();

xmlDocument.Load(FileInfo.FullName);

// bool FoundIt = false, FondReportServer = false;

            foreach (System.Xml.XmlNode Node in xmlDocument["configuration"]["appSettings"])
            {
                if (Node.Name == "add")
                {
                    if (Node.Attributes.GetNamedItem("key").Value == "SqlConnectionString")
                    {

                       string strNodeConnection= Node.Attributes.GetNamedItem("value").Value ;//= String.Format("Persist Security Info=False;Data Source={0};database={1};User ID={2};Password={3};Packet Size=4096;Pooling=true;Max Pool Size=100;Min Pool Size=1", ServerName, DBName, AdminName, AdminPwd);
                       if (string.IsNullOrEmpty(strNodeConnection))
                       {
                           int dataBaseIndex=strNodeConnection.IndexOf("database=")+10;
                           int dataBaseEnd = strNodeConnection.Substring(dataBaseIndex, strNodeConnection.Length - dataBaseIndex - 1).IndexOf(";");
                           MessageBox.Show(strNodeConnection.Substring(dataBaseIndex, dataBaseEnd));
                           return strNodeConnection.Substring(dataBaseIndex,dataBaseEnd);
                       }
                    }

                }
            }
            return string.Empty;

}

#endregion

#region WriteRegistryKey 写注册表。安装部署中，直接有一个注册表编辑器，可以在那里面设置。

        private void WriteRegistryKey()
        {
            // 写注册表

RegistryKey hklm = Registry.LocalMachine;

RegistryKey qzg = hklm.OpenSubKey("SOFTWARE", true);

RegistryKey F = qzg.CreateSubKey("QzgWygl");

//F.SetValue("FilePath", "kkkk"); old
F.SetValue("FilePath", "QzgFxWygl");

}

#endregion

//操作IIS，建立网站等。可参考：

        //用VS2005制作网页对IIS进行操作
        #region Connect 连接IIS服务器
        public bool Connect()
        {
            if (iis == null)

return false;

try

{

_iisServer = new DirectoryEntry("IIS://" + iis + "/W3SVC/1");

_target = iis;

_connection = new ConnectionOptions();

_scope = new ManagementScope(@"\\" + iis + @"\root\MicrosoftIISV2", _connection);

_scope.Connect();

}

catch

{

return false;

}

return IsConnected();

}

public bool IsConnected()

{

if (_target == null || _connection == null || _scope == null) return false;

return _scope.IsConnected;

}

#endregion

#region IsWebSiteExists 判断网站是否已经存在

public bool IsWebSiteExists(string serverID)

{

try

{

string siteName = "W3SVC/" + serverID;

ManagementObjectSearcher searcher = new ManagementObjectSearcher(_scope, new ObjectQuery("SELECT * FROM IIsWebServer"), null);

ManagementObjectCollection webSites = searcher.Get();

foreach (ManagementObject webSite in webSites)

{

if ((string)webSite.Properties["Name"].Value == siteName)

return true;

}

return false;

}

catch

{

return false;

}

#endregion

#region GetNextOpenID 获得一个新的ServerID

private int GetNextOpenID()

{

DirectoryEntry iisComputer = new DirectoryEntry("IIS://localhost/w3svc");

int nextID = 0;

foreach (DirectoryEntry iisWebServer in iisComputer.Children)
{

string sname = iisWebServer.Name;

try

{

int name = int.Parse(sname);

if (name > nextID)

{

nextID = name;

}

catch

{

}

return ++nextID;

}

#endregion

#region CreateWebsite 添加网站

public string CreateWebSite(string serverID, string serverComment, string defaultVrootPath, string HostName, string IP, string Port)

{

try

{

ManagementObject oW3SVC = new ManagementObject(_scope, new ManagementPath(@"IIsWebService='W3SVC'"), null);

if (IsWebSiteExists(serverID))

{

return "Site Already Exists...";

}

ManagementBaseObject inputParameters = oW3SVC.GetMethodParameters("CreateNewSite");

ManagementBaseObject[] serverBinding = new ManagementBaseObject[1];

serverBinding[0] = CreateServerBinding(HostName, IP, Port);

inputParameters["ServerComment"] = serverComment;

inputParameters["ServerBindings"] = serverBinding;

inputParameters["PathOfRootVirtualDir"] = defaultVrootPath;

inputParameters["ServerId"] = serverID;

ManagementBaseObject outParameter = null;

outParameter = oW3SVC.InvokeMethod("CreateNewSite", inputParameters, null);

// 启动网站

string serverName = "W3SVC/" + serverID;

ManagementObject webSite = new ManagementObject(_scope, new ManagementPath(@"IIsWebServer='" + serverName + "'"), null);

webSite.InvokeMethod("Start", null);

return (string)outParameter.Properties["ReturnValue"].Value;

            }
            catch (Exception ex)
            {

return ex.Message;

}

//创建网站管理服务
public ManagementObject CreateServerBinding(string HostName, string IP, string Port)

{

try

{

ManagementClass classBinding = new ManagementClass(_scope, new ManagementPath("ServerBinding"), null);

ManagementObject serverBinding = classBinding.CreateInstance();

serverBinding.Properties["Hostname"].Value = HostName;

serverBinding.Properties["IP"].Value = IP;

serverBinding.Properties["Port"].Value = Port;

serverBinding.Put();

return serverBinding;

}

catch

{

return null;

}

#endregion

//好了，准备工作已经做完，现在开始写最重要的Install方法了

//整个方法写完后如下：

#region Install 安装

///

/// 安装数据库

///

public override void Install(IDictionary stateSaver)

{
base.Install(stateSaver);

dir = this.Context.Parameters["targetdir"];

            DBName = this.Context.Parameters["dbname"].ToString();


            ServerName = this.Context.Parameters["server"].ToString();

AdminName = this.Context.Parameters["user"].ToString();

AdminPwd = this.Context.Parameters["pwd"].ToString();

iis = this.Context.Parameters["iis"].ToString();

            port = this.Context.Parameters["port"].ToString();

            //MessageBox.Show("Initial-"+DBName+"-"+ServerName+"-"+AdminName+"-"+AdminPwd+"-iis:"+iis+"-"+port+"-"+dir+"}");

            //写入获取的安装程序中的变量，此段代码为调试用可以不添加
            if(sqlConn==null)
            sqlConn = new SqlConnection();
            this.sqlConn.ConnectionString = "Packet size=4096;User ID=" + AdminName + ";Data Source=" + ServerName + ";Password=" + AdminPwd + ";Persist Security Info=False;Integrated Security=false";

            //本安装程序采用附加数据库的方式，所以去掉本段代码
            // 执行SQL 安装数据库可选择时恢复或者时直接创建
            //if (!CreateDBAndTable(DBName))
            //{
            //    MessageBox.Show("qzg-dbname");
            //    throw new ApplicationException("创建数据库时出现严重错误！");

//}

            // 从备份数据库文件恢复数据库
            if (!RestoreDB(DBName))
            {
                MessageBox.Show("恢复数据库时出现严重错误,请与管理员联系！");
            }

             //部署桌面快捷方式*******************#region//部署桌面快捷方式*******************
            string strDeskTop = System.Environment.GetFolderPath(Environment.SpecialFolder.DesktopDirectory);
            StreamWriter sw2 = System.IO.File.CreateText(strDeskTop + "\\亿联物业管理系统.url");
            stateSaver.Add("DeskQuick", strDeskTop + "\\亿联物业管理系统.url"); //保存桌面快诫方式文件绝对地址

            string[] aryTh = dir.TrimEnd('\\').Split('\\');
            string webdirs = aryTh[aryTh.Length-1];

             string Urls = @"URL=http://"+iis+"/" + webdirs + @"/default.aspx";
             sw2.WriteLine("[InternetShortcut]");
             sw2.WriteLine(Urls);
             sw2.WriteLine("modified=228928983");
             sw2.WriteLine("IconIndex=0");
             sw2.WriteLine("IconFile=" + dir + "http://www.cnblogs.com/bingyun84/admin/file://wygl.ico/");
             sw2.Flush();
             sw2.Close();
             //#endregio
             ////部署开始菜单 ***************#region 部署开始菜单 ***************
             string startMenue=Environment.GetFolderPath(Environment.SpecialFolder.StartMenu);

             if(File.Exists(startMenue+"\\亿联物业管理系统.url"))
             {
                  if(MessageBox.Show("开始菜单已经存在,是否有覆盖它?","安装开始菜单",MessageBoxButtons.YesNo,MessageBoxIcon.Question,
                   MessageBoxDefaultButton.Button1) == DialogResult.Yes)
                  {

                      File.Copy(strDeskTop + "\\亿联物业管理系统.url", startMenue + "\\亿联物业管理系统.url", true);
                  }
                  else
                  {
                    throw new InstallException("开始菜单已经存在,安装取消");
                  }
             }
             else
             {

                 File.Copy(strDeskTop + "\\亿联物业管理系统.url", startMenue + "\\亿联物业管理系统.url", false);
             }
             stateSaver.Add("StartMenueFile",startMenue+"\\亿联物业管理系统.url"); //保存开始菜单文件绝对地址

            // 添加网站
            Connect();
            // 下面的信息为测试，可以自己编写文本框来接收用户输入信息

string serverID = "5555";

string serverComment = "QZG";

string defaultVrootPath = this.Context.Parameters["targetdir"];

            if (defaultVrootPath.EndsWith(@"\"))
            {
                defaultVrootPath = defaultVrootPath.Substring(0, defaultVrootPath.Length-1);

}

string HostName = "";

string IP = "";

string Port = port;

string sReturn = CreateWebSite(serverID, serverComment, defaultVrootPath, HostName, IP, Port);

            // 修改web.config
            if (!WriteWebConfig())
            {

                //throw new ApplicationException("设置数据库连接字符串时出现错误");
                MessageBox.Show("设置数据库连接字符串时出现错误");

            }
            // 写注册表
            WriteRegistryKey();
        }

#endregion

//删除时的方法。在本文中未详细操作，比如删除站点，删除数据库等。如果需要，请你自己补足

#region Uninstall 删除

        //QZG
        private bool DeleteDatabase()
        {
            try
            {
                DBName = this.Context.Parameters["dbname"].ToString();
                if (string.IsNullOrEmpty(DBName))
                {
                  DBName= GetDBNameFromWebConfig();
                }
                if (string.IsNullOrEmpty(DBName))
                    return false;
                ExecuteSql("master", "USE MASTER IF EXISTS (SELECT NAME FROM SYSDATABASES WHERE NAME='" + DBName + "') DROP DATABASE "+DBName+" ");
                return true;

            }
            catch
            {
                return false;
            }
        }
        public override void Uninstall(IDictionary savedState)
        {
            //MessageBox.Show("卸载过程....");
            if (savedState == null)
                throw new ApplicationException("卸载数据库失败,未能卸载![qzg]");
            else
            {
                 base.Uninstall(savedState);
                 //删除快捷键,删除开始菜单#region 删除快捷键,删除开始菜单
                 //删除快捷键
                 if(File.Exists(savedState["DeskQuick"].ToString()))
                 {
                  File.Delete(savedState["DeskQuick"].ToString());
                 }
                 //删除开始菜单
                 if(File.Exists(savedState["StartMenueFile"].ToString()))
                 {
                  File.Delete(savedState["StartMenueFile"].ToString());
                 }
                 //#endregion
                if (!DeleteDatabase())
                {
                    MessageBox.Show("卸载数据库错误，请手动删除物业管理系统的数据库!");
                    //throw new ApplicationException("卸载过程中发生错误，未能卸载！");
                }

            }