读取Excel内容，导入数据库多张表！

客户要求用Excel记录联系人资料，并导入数据库，找了个第3方Wizard控件做了个小功能。
Excel每一个sheet为一个企业名，为了避免麻烦，一次性导入所有联系人。
 同一企业下的相同姓名，相同手机号的为同一个联系人，就不导入。
Excel表中，有些字段不在同一张表：“部门”、“职务”。判断部门和职务是否存在，若不存在添加到部门和职务表，返回ID。
几次测试，取手机号等字段出错，原来要把Excel单元格格式设为文本。




/**//*         Author : Magicam 


 *         Date   : 1 August 2007


 *         e-mail : wx_magicam@sina.com


 */        


using System;


using System.Collections.Generic;


using System.ComponentModel;


using System.Data;


using System.Drawing;


using System.Text;


using System.Windows.Forms;


using System.Data.SqlClient;


using System.Data.OleDb;


using CristiPotlog.Controls;//引用第3方向导式控件


using System.Configuration;




namespace Excel






{


    public partial class ExcelForm : Form




    

{


        public ExcelForm()




        

{


            InitializeComponent();


        }




        public static readonly string ConnectionString = ConfigurationManager.ConnectionStrings[ "DataConnectionString" ].ConnectionString;






        /**//// <summary>


        /// 完成按钮


        /// </summary>


        /// <param name="sender"></param>


        /// <param name="e"></param>


        private void wizard1_Finish( object sender, EventArgs e )




        

{


            MessageBox.Show( "导入成功！", this.Text, MessageBoxButtons.OK, MessageBoxIcon.Information );


        }




        private void wizard1_Cancel( object sender, CancelEventArgs e )




        

{


            bool isTaskRunning = this.timer1.Enabled;


            this.timer1.Enabled = false;




            if ( MessageBox.Show( "确定退出吗?", this.Text, MessageBoxButtons.YesNo, MessageBoxIcon.Question ) != DialogResult.Yes )




            

{


                e.Cancel = true;


                this.timer1.Enabled = isTaskRunning;


            }


        }






        /**//// <summary>


        /// time控件


        /// </summary>


        /// <param name="sender"></param>


        /// <param name="e"></param>


        private void timer1_Tick( object sender, EventArgs e )




        

{


            if ( this.progressBar1.Value == this.progressBar1.Maximum )




            

{


                this.timer1.Enabled = false;


                this.wizard1.Next();


            }


            else




            

{


                this.progressBar1.PerformStep();


            }


        }






        /**//// <summary>


        /// 选择Excel按钮


        /// </summary>


        /// <param name="sender"></param>


        /// <param name="e"></param>


        private void btnChooseExcel_Click( object sender, EventArgs e )




        

{


            OpenFileDialog openFileDialog = new OpenFileDialog();


            openFileDialog.Filter = "Microsoft Excel 文件(*.xls)|*.xls";


            openFileDialog.Title = "选择Excel文件";




            if ( DialogResult.Cancel == openFileDialog.ShowDialog())




            

{


                return;


            }




            string ExcelPath = openFileDialog.FileName;


            txtExcelPath.Text = ExcelPath;




            string ConnectionExcel = "Provider=Microsoft.Jet.OLEDB.4.0;" + "Data Source=" + ExcelPath + ";" + "Extended Properties=Excel 8.0;";




            OleDbConnection conn = new OleDbConnection( ConnectionExcel );


            conn.Open();


            System.Data.DataTable schemaTable = conn.GetOleDbSchemaTable( System.Data.OleDb.OleDbSchemaGuid.Tables, null );




            dataGridView1.Rows.Clear();


            dataGridView1.Columns.Clear();




            //定义dataGridView第一列


            dataGridView1.RowHeadersVisible = false;


            DataGridViewTextBoxColumn textColumn = new DataGridViewTextBoxColumn();


            textColumn.HeaderText = "工作表";


            dataGridView1.Columns.Insert( 0, textColumn );


            //定义dataGridView第二列


            DataGridViewComboBoxColumn comboColumn = new DataGridViewComboBoxColumn();


            comboColumn.HeaderText = "选择企业";


            comboColumn.AutoComplete = true;


            dataGridView1.Columns.Insert( 1, comboColumn );




            SqlConnection con = new SqlConnection( ConnectionString );


            con.Open();




            for( int i = 0; i < schemaTable.Rows.Count; i++ )




            

{


                //取出Excel工作表名导入dataGridView第一列




                string tableName = schemaTable.Rows[ i ][ 2 ].ToString().Trim( new char[] 

{ '$', '/'' } );


                dataGridView1.Rows.Add();


                dataGridView1.Rows[ i ].Cells[ 0 ].Value = tableName;




                OnInitComboBox( i );


            }          


        }




        private void OnInitComboBox( int row )




        

{


            //第二列根据第一列做模糊查询，供用户选择企业名


            SqlConnection con = new SqlConnection( ConnectionString );


            con.Open();




            SqlDataAdapter sda = new SqlDataAdapter();


            DataSet ds = new DataSet();




            string name = dataGridView1.Rows[ row ].Cells[ 0 ].Value.ToString();


            string str = "select id, name from enterprise where name like '%" + name + "%'";




            sda.SelectCommand = new SqlCommand( str, con );


            sda.Fill( ds, "enterprise" );




            (( DataGridViewComboBoxCell )( dataGridView1.Rows[ row ].Cells[ 1 ] )).DataSource    = ds.Tables[ 0 ].DefaultView;


            (( DataGridViewComboBoxCell )( dataGridView1.Rows[ row ].Cells[ 1 ] )).ValueMember   = "id";


            (( DataGridViewComboBoxCell )( dataGridView1.Rows[ row ].Cells[ 1 ] )).DisplayMember = "name";


        }




        private void wizard1_BeforeSwitchPages( object sender, Wizard.BeforeSwitchPagesEventArgs e )




        

{


            WizardPage oldPage = this.wizard1.Pages[ e.OldIndex ];




            if ( oldPage == this.ChooseExcelPage && e.NewIndex > e.OldIndex )




            

{                


                if ( txtExcelPath.Text == "" )




                

{                   


                    MessageBox.Show( "请选择一个Excel文件！", this.Text, MessageBoxButtons.OK, MessageBoxIcon.Information );


                    e.Cancel = true;


                }


            }


            else if( oldPage == this.ChooseEnterprisePage && e.NewIndex > e.OldIndex )




            

{


                SqlConnection con = new SqlConnection( ConnectionString );


                con.Open();




                for( int i = 0; i<dataGridView1.Rows.Count; i++ )




                

{


                    if( dataGridView1.Rows[ i ].Cells[ 1 ].Value == null )




                    

{


                        MessageBox.Show( "请选择企业！",  this.Text, MessageBoxButtons.OK, MessageBoxIcon.Information );                        


                        e.Cancel = true;


                    }                    


                }


            }


            else if( oldPage == this.ProgressPage && e.NewIndex > e.OldIndex )




            

{


                //导入数据库 


                for( int i = 0; i<dataGridView1.Rows.Count; i++ )




                

{


                    //读取Excel内容到table


                    DataSet DataSet = ReadExcelToTable( i );                                 




                    for( int j = 0; j<DataSet.Tables[ 0 ].Rows.Count; j++ )




                    

{


                        SqlConnection con = new SqlConnection( ConnectionString );


                        con.Open();   


                        SqlTransaction transaction;


                        transaction = con.BeginTransaction();


                        try




                        

{


                            //判断联系人是否重复，若重复跳出循环，不添加


                            string LinkmanName = DataSet.Tables[ 0 ].Rows[ j ].ItemArray[ 0 ].ToString();


                            string LinkmanMobile = DataSet.Tables[ 0 ].Rows[ j ].ItemArray[ 3 ].ToString();


                            SqlCommand selectLinkmanName = new SqlCommand();


                            selectLinkmanName.Connection = con;


                            selectLinkmanName.CommandText = "select count( * ) from linkman where enterpriseid='" + dataGridView1.Rows[i].Cells[1].Value.ToString() + "'and name='" + LinkmanName + "' and mobile='" + LinkmanMobile + "'";


                            selectLinkmanName.Transaction = transaction;


                            int LinkmanCount = Convert.ToInt32( selectLinkmanName.ExecuteScalar());




                            if( LinkmanCount > 0 )




                            

{


                                continue;                               


                            }            




                            //判断是否存在该部门,不存在添加                   


                            int departmentID = ExistDepartment( con, DataSet, j, transaction );




                            //判断是否存在该职务，不存在添加


                            int dutyID = ExistDuty( con, DataSet, j, transaction );




                            //导入数据库


                            InsertTOSql( con, i, DataSet, j, departmentID, dutyID, transaction );


                        }


                        catch( Exception e1 )




                        

{


                            transaction.Rollback();        


                        }


                        finally




                        

{


                            transaction.Commit();


                            con.Close();


                        }


                    }


                } 


            }


        }




        private void InsertTOSql( SqlConnection con, int i, DataSet DataSet, int j, int departmentID, int dutyID, SqlTransaction transaction )




        

{


            SqlCommand insertToSql = new SqlCommand();


            insertToSql.Connection = con;


            insertToSql.CommandText = @"insert into linkman( enterpriseID, name, departmentID, dutyID, mobile, phone, email, fax, IsLinkman )


                                      values( " + dataGridView1.Rows[ i ].Cells[ 1 ].Value.ToString() + ", '" + DataSet.Tables[ 0 ].Rows[ j ].ItemArray[ 0 ].ToString() + "', " + departmentID + ", "


                          + dutyID + ", '" + DataSet.Tables[ 0 ].Rows[ j ].ItemArray[ 3 ].ToString() + "', '" + DataSet.Tables[ 0 ].Rows[ j ].ItemArray[ 4 ].ToString() + "', '" +


                          DataSet.Tables[ 0 ].Rows[ j ].ItemArray[ 5 ].ToString() + "', '" + DataSet.Tables[ 0 ].Rows[ j ].ItemArray[ 6 ].ToString() + "', 1 )"; 


            insertToSql.Transaction = transaction;


            insertToSql.ExecuteNonQuery();            


        }




        private static int ExistDuty( SqlConnection con, DataSet DataSet, int j, SqlTransaction transaction )




        

{


            SqlCommand selectDuty = new SqlCommand();


            selectDuty.Connection = con;


            selectDuty.CommandText = "select id from duty where name ='" + DataSet.Tables[ 0 ].Rows[ j ].ItemArray[ 2 ].ToString() + "'";


            selectDuty.Transaction = transaction;


            int dutyID = Convert.ToInt32( selectDuty.ExecuteScalar());


            if ( dutyID == 0 )




            

{


                SqlCommand insertDuty = new SqlCommand();


                insertDuty.Connection = con;


                insertDuty.CommandText = "insert into duty( name ) values( '" + DataSet.Tables[0].Rows[ j ].ItemArray[ 2 ].ToString() + "')";


                insertDuty.Transaction = transaction;


                insertDuty.ExecuteNonQuery(); 


               


                dutyID = GetID( con, transaction );


            }


            return dutyID;


        }




        private static int ExistDepartment( SqlConnection con, DataSet DataSet, int j, SqlTransaction transaction )




        

{


            SqlCommand selectDepartment = new SqlCommand();


            selectDepartment.Connection = con;


            selectDepartment.CommandText = "select id from department where name = '" + DataSet.Tables[ 0 ].Rows[ j ].ItemArray[ 1 ].ToString() + "'";


            selectDepartment.Transaction = transaction;


            int departmentID = Convert.ToInt32( selectDepartment.ExecuteScalar());


            if ( departmentID == 0 )




            

{


                SqlCommand insertDepartment = new SqlCommand();


                insertDepartment.Connection = con;




                insertDepartment.CommandText = "insert into department( name ) values( '" + DataSet.Tables[ 0 ].Rows[ j ].ItemArray[ 1 ].ToString() + "' )";


                insertDepartment.Transaction = transaction;


                insertDepartment.ExecuteNonQuery();


               


                departmentID = GetID( con, transaction );


            }


            return departmentID;


        }




        private static int GetID( SqlConnection con, SqlTransaction transaction )




        

{


            string sql = "select @@identity";


            SqlCommand command = new SqlCommand( sql, con );


            command.Transaction = transaction;


            return Convert.ToInt32( command.ExecuteScalar());


        }




        private DataSet ReadExcelToTable( int i )




        

{


            string ConnectionExcel = "Provider=Microsoft.Jet.Oledb.4.0;Data Source='" + txtExcelPath.Text + "';Extended Properties=Excel 8.0";


            OleDbConnection connection = new OleDbConnection( ConnectionExcel );


            OleDbDataAdapter adp = new OleDbDataAdapter( "Select * from  [" + dataGridView1.Rows[ i ].Cells[ 0 ].Value.ToString() + "$]", connection );


            DataSet DataSet = new DataSet();


            adp.Fill( DataSet, "Book1" );


            return DataSet;


        }




        private void wizard1_AfterSwitchPages( object sender, Wizard.AfterSwitchPagesEventArgs e )




        

{


            WizardPage newPage = this.wizard1.Pages[ e.NewIndex ];




            if( newPage == this.ChooseExcelPage )




            

{


                this.wizard1.NextEnabled = this.ChooseEnterprisePage.Enabled;


            }


            else if( newPage == this.ChooseEnterprisePage )




            

{


                this.wizard1.NextEnabled = this.ProgressPage.Enabled;


            }


            else if( newPage == this.ProgressPage)




            

{


                this.wizard1.BackEnabled = false;


                this.wizard1.NextEnabled = false;


                this.progressBar1.Value = this.progressBar1.Minimum;


                this.timer1.Enabled = true;


            }


        }


    }


}