winform 批量导入本地sql文件，批量导入mdb（access）文件到sqlserver

0.数据库连接

 private void button1_Click(object sender, EventArgs e)
        {
            this.btnUpdate.Enabled = false;
            #region 数据库连接
            connStr.Append("Data Source=");
            connStr.Append(txtServer.Text);
            connStr.Append(";");
            connStr.Append("Initial Catalog=");
            connStr.Append(txtDataBase.Text);
            connStr.Append(";");
            connStr.Append("User ID=");
            connStr.Append(txtUser.Text);
            connStr.Append(";");
            connStr.Append("Password=");
            connStr.Append(txtPass.Text);
            this.labShow.Text = "正在查找文件......";
            using (SqlConnection conn = new SqlConnection(connStr.ToString()))
            {
                //MessageBox.Show(connStr.ToString());
                ListSql = new List<string>();
                ListMdb = new List<string>();
                GetDirectories(Application.StartupPath);
                //ListSql.Sort(new MySort());

                foreach (var item in ListSql)
                {
                    GetSqlFile(item);
                }
                foreach (var item in ListMdb)
                {
                    ReadDataToSQL(item);
                }
                MessageBox.Show("升级成功......");
                this.btnUpdate.Enabled = true;
                Application.Exit();
            }
            #endregion

        }

1.查找文件与目录

 #region 查找目录与文件
        public void GetDirectories(string path)
        {
            
            string[] fileNames = Directory.GetFiles(path);
            string[] directories = Directory.GetDirectories(path);
            foreach (string file in fileNames)
            {
                string str = System.IO.Path.GetFullPath(path);
                if (System.IO.Path.GetExtension(file).ToLower() == ".sql")
                {
                    ListSql.Add(file);
                    //GetSqlFile(file);
                }
                if (System.IO.Path.GetExtension(file).ToLower() == ".mdb")
                {
                    //ReadDataToSQL(file);
                    ListMdb.Add(file);
                }
            }
            
            foreach (string dir in directories)
            {
                GetDirectories(dir);
            }
        }
        #endregion

2.获取本地脚本文件、执行sql文件

 foreach (var item in ListSql)
                {
                    GetSqlFile(item);
                }

 #region 批量执行本地的sql文件到sqlServer数据库
        /// <summary>
        /// 获取本地的脚步文件
        /// </summary>
        private void GetSqlFile(string path)
        {
            try
            {
                string obj_file = this.GetFileReader(path);
                obj_file = obj_file.Replace("GO", " | ").Replace("go", " | ");//替换符号
                string[] obj_filelist = obj_file.Split('|');
                foreach (string str in obj_filelist)
                {
                    this.labShow.Text ="正在执行脚本"+ Path.GetFileName(path)+"文件......";
                    this.ExecSQL(str);
                }
               // MessageBox.Show("导入成功!", "ERROR", MessageBoxButtons.OK, MessageBoxIcon.Asterisk);
            }
            catch
            {

            }
        }
        /// <summary>
        /// 获取文件内容
        /// </summary>
        /// <param name="path">文件路径</param>
        /// <returns>返回sql文件的执行语句</returns>
        public string GetFileReader(string path)
        {
            try
            {
                using (StreamReader sr = new StreamReader(path, Encoding.Default))
                {
                    String line = sr.ReadToEnd();

                    return line;
                }
            }
            catch (Exception ex)
            {
                return "";
            }
        }
        /// <summary>
        /// 执行SQL
        /// </summary>
        /// <param name="SQL"></param>
        public void ExecSQL(string SQL)
        {
            try
            {
                using (SqlConnection conn = new SqlConnection(@"Data Source=(local);Initial Catalog=数据库名称;User ID=用户名;Password=密码"))
                {
                    conn.Open();
                    using (SqlCommand cmd = new SqlCommand(SQL, conn))
                    {
                        cmd.CommandType = CommandType.Text;
                        cmd.ExecuteNonQuery();
                    }
                    conn.Close();
                }
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message + "|" + ex.Source);

            }
        }
        #endregion

3.获取mdb本地文件，执行读取与插入操作

#region 批量执行本地的mdb文件到sqlServer数据库
        /// <summary>
        ///读取access数据库中的数据并插入到sqlServer数据库表中
        /// </summary>
        /// <param name="file">文件路径</param>
        private void ReadDataToSQL(string file)
        {
            try
            {
                this.labShow.Text = "正在执行脚本" + Path.GetFileName(file) + "文件......";
                string StrConn = "Provider=Microsoft.Jet.OLEDB.4.0;Jet OLEDB:Database Password=;Data source=" + file + "";
                OleDbConnection adoConn = new OleDbConnection(StrConn);
                //adoConn.ConnectionString = StrConn;
                adoConn.Open();
                DataTable dt = adoConn.GetOleDbSchemaTable(OleDbSchemaGuid.Tables, new object[] { null, null, null, "TABLE" });
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    String tableName = dt.Rows[i]["TABLE_NAME"].ToString();

                    //从ACCESS数据库查询数据
                    string sql1 = "select * from " + tableName;
                    DataSet Myds = new DataSet();
                    OleDbDataAdapter dataAdapter = new OleDbDataAdapter(sql1, adoConn);
                    //填充数据
                    dataAdapter.Fill(Myds, tableName);
                    //插入数据
                    BulkData(Myds, tableName);
                }
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }
        /// <summary>
        /// 执行Sql语句
        /// </summary>
        /// <param name="_Ds">DataSet数据集</param>
        /// <param name="_TableName">表名称</param>
        /// <returns>是否成功</returns>
        public bool BulkData(DataSet _Ds, string _TableName)
        {
            SqlConnection SqlCon = new SqlConnection();
            SqlCon.ConnectionString = connStr.ToString();
            SqlCon.Open();
            SqlBulkCopy SqlBulk = new SqlBulkCopy(SqlCon);
            SqlBulk.DestinationTableName = _TableName;
            try
            {
                SqlBulk.WriteToServer(_Ds.Tables[0], DataRowState.Unchanged);
                return true;
            }
            catch(Exception ex)
            {
                MessageBox.Show(ex.ToString());
                return false;
            }
            finally
            {
                SqlCon.Close();
                SqlCon.Dispose();
                SqlBulk.Close();
            }
        }
#endregion