usingSystem;  
usingSystem.Collections;  
usingSystem.ComponentModel;  
usingSystem.Configuration.Install;  
usingSystem.Reflection;  
usingSystem.IO;  
usingSystem.Data;  
usingSystem.Data.SqlClient;  
namespaceinstall{  
///  
///Installer1的摘要說明。  
///  
[RunInstaller(true)]  
publicclassInstaller1:System.Configuration.Install.Installer{  
///  
///必需的設計器變量。  
///  
privateSystem.ComponentModel.Containercomponents=null;  
publicInstaller1(){  
//該調用是設計器所必需的。  
InitializeComponent();  
//TODO:在InitializeComponent調用后添加任何初始化  
}  
///  
///清理所有正在使用的資源。  
///  
protectedoverridevoidDispose(booldisposing){  
if(disposing){  
if(components!=null){  
components.Dispose();  
}  
}  
base.Dispose(disposing);  
}  
 
#region組件設計器生成的代碼  
///  
///設計器支持所需的方法-不要使用代碼編輯器修改  
///此方法的內容。  
///  
privatevoidInitializeComponent(){  
components=newSystem.ComponentModel.Container();  
}  
#endregion  
privatestringGetSql(stringName){  
////調用osql執行腳本  
//  
//System.Diagnostics.ProcesssqlProcess=newSystem.Diagnostics.Process();  
//  
//sqlProcess.StartInfo.FileName="osql.exe";  
//  
//sqlProcess.StartInfo.Arguments=String.Format("-U{0}-P{1}-d{2}-i{3}db.sql",
this.Context.Parameters["user"],this.Context.Parameters["pwd"],"master",this.
Context.Parameters["targetdir"]);  
//  
//sqlProcess.StartInfo.WindowStyle=System.Diagnostics.ProcessWindowStyle.Hidden;  
//  
//sqlProcess.Start();  
//  
//sqlProcess.WaitForExit();//等待執行  
//  
//sqlProcess.Close();  
try{  
//AssemblyAssemblyAsm=Assembly.GetExecutingAssembly();  
//System.IO.FileInfoFileInfo=newSystem.IO.FileInfo(Asm.Location);  
//stringpath=FileInfo.DirectoryName+@"\"+Name;  
stringpath=this.Context.Parameters["targetdir"]+Name;  
FileStreamfs=newFileStream(path,FileMode.Open,FileAccess.Read,FileShare.Read);  
StreamReaderreader=newStreamReader(fs,System.Text.Encoding.Default);  
//System.Text.Encoding.ASCII;  
returnreader.ReadToEnd();  
}  
catch(Exceptionex){  
Console.Write("InGetSql:"+ex.Message);  
throwex;  
}  
}  
privatevoidExecuteSql(stringDataBaseName,stringSql){  
SqlConnectionsqlConnection1=newSqlConnection();  
sqlConnection1.ConnectionString=string.Format("server={0};userid={1};password={2};
Database=master",this.Context.Parameters["server"],this.Context.Parameters["user"],
this.Context.Parameters["pwd"]);  
System.Data.SqlClient.SqlCommandCommand=newSystem.Data.SqlClient.
SqlCommand(Sql,sqlConnection1);  
try{  
Command.Connection.Open();  
Command.Connection.ChangeDatabase(DataBaseName);  
Command.ExecuteNonQuery();  
}  
catch(Exceptionex){  
Console.Write("Inexceptionhandler:"+ex.Message);  
}  
finally{  
Command.Connection.Close();  
}  
}  
protectedvoidAddDBTable(stringstrDBName){  
try{  
ExecuteSql("master","CREATEDATABASE"+strDBName);  
ExecuteSql(strDBName,GetSql("sql.txt"));  
ExecuteSql("master","execsp_addlogin'myoamaster','myoamaster','"+strDBName+"',Null,Null");  
ExecuteSql(strDBName,"EXECsp_grantdbaccess'myoamaster','myoamaster'");  
ExecuteSql(strDBName,"execsp_addrolemember'db_owner','myoamaster'");  
}  
catch(Exceptionex){  
Console.Write("Inexceptionhandler:"+ex.Message);  
}  
}  
publicoverridevoidInstall(System.Collections.IDictionarystateSaver){  
base.Install(stateSaver);  
AddDBTable(this.Context.Parameters["dbname"]);  
}  
}  
}