/// <summary>
/// 建立資料庫
/// </summary>
/// <param name="connStr">連線字串</param>
/// <param name="_strDBName">資料庫名稱</param>
/// <returns></returns>
private static bool CreateDatabase(string connStr, string _strDBName)
{
	bool bSuccess = false;
	try
	{
		using (SqlConnection conMaster = new SqlConnection(connStr))
		{
			conMaster.Open();

			// Check if the Database has existed first
			string strExist = @"select * from dbo.sysdatabases where name='" + _strDBName + @"'";
			SqlCommand cmdExist = new SqlCommand(strExist, conMaster);
			SqlDataReader readerExist = cmdExist.ExecuteReader();
			bool bExist = readerExist.HasRows;
			readerExist.Close();
			if (bExist)
			{

				string strDel = @"drop database " + _strDBName;
				SqlCommand cmdDel = new SqlCommand(strDel, conMaster);

				cmdDel.ExecuteNonQuery();
			}

			// Create the database now;                   
			string strDatabase = "Create Database [" + _strDBName + "]";
			SqlCommand cmdCreate = new SqlCommand(strDatabase, conMaster);
			cmdCreate.ExecuteNonQuery();

			conMaster.Close();
		}

		bSuccess = true;
	}
	catch (Exception e)
	{
		throw e;
	}

	return bSuccess;
}
 

/// <summary>
/// 匯入sql指令碼
/// </summary>
/// <param name="sqlConnString">連線資料庫字串</param>
/// <param name="varFileName">指令碼路徑</param>
/// <returns></returns>
private static bool ExecuteSqlFile(string sqlConnString, string varFileName)
{
	if (!File.Exists(varFileName))
	{
		return false;
	}
	StreamReader rs = new StreamReader(varFileName, System.Text.Encoding.Default);
	ArrayList alSql = new ArrayList();
	string commandText = "";
	string varLine = "";
	while (rs.Peek() > -1)
	{
		varLine = rs.ReadLine();
		if (varLine == "")
		{
			continue;
		}
		if (varLine != "GO")
		{
			commandText += varLine;
			commandText += "\r\n";
		}
		else
		{
			commandText += "";
		}
	}
	alSql.Add(commandText);
	rs.Close();
	try
	{
		ExecuteCommand(sqlConnString, alSql);
		return true;
	}
	catch (Exception ex)
	{
		throw ex;
	}
}
 

private static void ExecuteCommand(string sqlConnString, ArrayList varSqlList)
        {
            using (SqlConnection conn = new SqlConnection(sqlConnString))
            {
                conn.Open();
                //Don't use Transaction, because some commands cannot execute in one Transaction.
                //SqlTransaction varTrans = conn.BeginTransaction();
                SqlCommand command = new SqlCommand();
                command.Connection = conn;
                //command.Transaction = varTrans;
                try
                {
                    foreach (string varcommandText in varSqlList)
                    {
                        command.CommandText = varcommandText;
                        command.ExecuteNonQuery();
                    }
                    //varTrans.Commit();
                }
                catch (Exception ex)
                {
                    //varTrans.Rollback();
                    throw ex;
                }
                finally
                {
                    conn.Close();
                }
            }
        }