managesqlscripts.cs

自己编写的基本Orcale的通用的数据库初始化工具。

using System;
using System.IO;

namespace DS.EMIS.StartPrepare.Common
{
	/// <summary>
	/// ManageSQLScripts 的摘要说明。SQL脚本读写控制类
	/// </summary>
	internal class ManageSQLScripts
	{
		public ManageSQLScripts()
		{
			//
			// TODO: 在此处添加构造函数逻辑
			//
		}

        /// <summary>
        /// 读取SQL脚本文件，使用文件流，自动加目录
        /// </summary>
        /// <param name="FileName">文件名，不带路径，如“EMIS_CreateTABSP.sql”</param>
        /// <returns></returns>
        public string ReadSQLScriptNO(string FileName)
        {
            try
            {
                string reValue = "";
                string currAppPath = AppDomain.CurrentDomain.SetupInformation.ApplicationBase;
                currAppPath += ".\\Resources\\Script\\"+FileName;
                FileStream  fs  =  new  FileStream(@currAppPath,FileMode.Open,FileAccess.Read);
                StreamReader  m_streamReader  =  new  StreamReader(fs)  ;  
                //使用StreamReader类来读取文件
                m_streamReader.BaseStream.Seek(0,SeekOrigin.Begin)  ;
                //  从数据流中读取每一行，直到文件的最后一行
                string  strLine  =  m_streamReader.ReadLine()  ;
                while(strLine!=null)
                {
                    reValue  +=  strLine  +  "\n"  ;
                    strLine  =  m_streamReader.ReadLine()  ;
                }
                //关闭此StreamReader对象
                return reValue;
            }
            catch(Exception  ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 脚本写入文件，自动加目录
        /// </summary>
        /// <param name="sqlString">脚本</param>
        /// <param name="FileName">文件名，不带路径，如“EMIS_CreateTABSP.sql”</param>
        /// <returns></returns>
        public void WriteSQLScriptNO(string FileName,string sqlString)
        {
            try
            {                
                string currAppPath = AppDomain.CurrentDomain.SetupInformation.ApplicationBase;
                currAppPath += ".\\Resources\\Script\\"+FileName;
                //创建一个文件流，用以写入或者创建一个StreamWriter
                FileStream  fs  =  new  FileStream(@currAppPath,FileMode.OpenOrCreate,FileAccess.Write)  ;
                StreamWriter  m_streamWriter  =  new  StreamWriter(fs)  ;
                m_streamWriter.Flush  (  )  ;
    
                //  使用StreamWriter来往文件中写入内容
                m_streamWriter.BaseStream.Seek(0, SeekOrigin.Begin)  ;
                //  把对象中的内容写入文件
                m_streamWriter.Write(sqlString)  ;
                //关闭此文件
                m_streamWriter.Flush()  ;
                m_streamWriter.Close()  ;
            }
            catch(Exception  ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 读去SQL脚本文件，使用文件流，不加目录
        /// </summary>
        /// <param name="FileName">文件名，如“EMIS_CreateTABSP.sql”</param>
        /// <returns></returns>
        public string ReadSQLScript(string FileName)
        {
            StreamReader reader = null;
            try
            {
                string reValue = "";
                string currAppPath = AppDomain.CurrentDomain.SetupInformation.ApplicationBase;
                currAppPath += ".\\Resources\\Script\\"+FileName;
				if(System.IO.Path.IsPathRooted(FileName))
				{
					reader = new StreamReader(FileName,System.Text.Encoding.Default);
				}
				else
				{
					reader = new StreamReader(currAppPath,System.Text.Encoding.Default);
				}
                reValue = reader.ReadToEnd();
                return reValue;
            }
            catch(Exception  ex)
            {
                throw ex;
            }
            finally
            {
                reader.Close();
            }
        }

        /// <summary>
        /// 脚本写入文件，不加目录
        /// </summary>
        /// <param name="sqlString">脚本</param>
        /// <param name="FileName">文件名，如“EMIS_CreateTABSP.sql”</param>
        /// <returns></returns>
        public void WriteSQLScript(string FileName,string sqlString)
        {
            System.IO.StreamWriter writer = null;
			try
			{                
				string currAppPath = AppDomain.CurrentDomain.SetupInformation.ApplicationBase;
				currAppPath += ".\\Resources\\Script\\"+FileName;
                
				sqlString = sqlString.Replace("\n","\r\n");
				if(System.IO.Path.IsPathRooted(FileName))
				{
					writer = new StreamWriter(FileName,false,System.Text.Encoding.UTF8);
				}
				else
				{
					writer = new StreamWriter(currAppPath,false,System.Text.Encoding.UTF8);				
				}
				writer.Flush();
				writer.Write(sqlString); 
				writer.Flush();
				writer.Close();               
			}
			catch(Exception  ex)
			{
				throw ex;
			}
			finally
			{
				writer.Close();    
			}
        }

	}
}