C# Excel导入Access

/// <summary>
/// 导入
/// </summary>
private void btn_In_Click(object sender, EventArgs e)
{
    int i = DataTableToDB();
    MessageBox.Show("成功导入" + i + "条商品信息！");
}




/// <summary>
/// 获取后缀名为*.xlsx的文件
/// </summary>
public void GetFile()
{
     System.IO.DirectoryInfo dir = new DirectoryInfo(VPath);
     if (dir.Exists)//判读是否存在改文件
     {
         fiList = dir.GetFiles("*.xlsx"); //获取后缀名为*.xlsx的文件
     }
}


/// <summary>
/// Excel数据转化为DataTable
/// </summary>
/// <param name="strSheetName"></param>
/// <param name="strExcelFileName">文件路径</param>
/// <returns>返回DataTable</returns>
public DataTable ExcelToDataTable(string strExcelFileName, string strSheetName)
{
    string strConn = string.Format("Provider=Microsoft.ACE.OLEDB.12.0;Data Source={0};Extended Properties='Excel 8.0;HDR=NO;IMEX=1;'", strExcelFileName);
    string strExcel = string.Format("select * from [{0}$]", strSheetName);
    DataSet ds = new DataSet();

    using (OleDbConnection conn = new OleDbConnection(strConn))
    {
        conn.Open();
        OleDbDataAdapter adapter = new OleDbDataAdapter(strExcel, strConn);
        adapter.Fill(ds, strSheetName);
        conn.Close();
    }

    return ds.Tables[strSheetName];
}



public int DataTableToDB()
{
    GetFile();
    int count = 0;
    string _strExcelFileName = "";
    for (int i = 0; i < fiList.Length; i++)
    {
        _strExcelFileName = dir + "\" + fiList[i];

        DataTable dtExcel = Global.g_objDb.ExcelToDataTable(_strExcelFileName, "Sheet1");
        for (int j = 0; j < dtExcel.Rows.Count; j++)
        {
            if ((ReturnSqlResultCount("select * from A where a1='" + dtExcel.Rows[j][0].ToString() + "'")) > 0)
            {
                continue;
            }
            else
            {
                Global.g_objDb.InsertDataToAccess(dtExcel.Rows[j][0].ToString(), dtExcel.Rows[j][1].ToString(), dtExcel.Rows[j][2].ToString(), dtExcel.Rows[j][3].ToString(), dtExcel.Rows[j][4].ToString(), dtExcel.Rows[j][5].ToString(), dtExcel.Rows[j][6].ToString(), dtExcel.Rows[j][7].ToString());

                count++;
            }
        }
    }
 
    return count;
}

String connectionString = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=Access_DataBase.mdb;Jet OLEDB:Database Password=123456""; 

OleDbConnection Connection = new OleDbConnection(connectionString);  

/// <summary>
/// 执行一查询语句语句，同时返回bool值
/// </summary>
public bool InsertDataToAccess(string col1, string col2, string col3, string col4, string col5, string col6, string col7, string col8)
{
    bool resultState = false;

    Connection.Open();
    string strSQL = "insert into spdm(a,b,c,d,e,f,g,h) values('" + col1 + "','" + col1 + "','" + col1 + "','" + col1 + "','" + col1 + "','" + col1 + "','" + col1 + "','" + col1 + "')";
    OleDbTransaction myTrans = Connection.BeginTransaction();
    OleDbCommand command = new OleDbCommand(strSQL, Connection, myTrans);

    try
    {
        command.ExecuteNonQuery();
        myTrans.Commit();
        resultState = true;
    }
    catch
    {
        myTrans.Rollback();
        resultState = false;
    }
    finally
    {
        Connection.Close();
    }
    return resultState;
}

/// <summary>
/// 执行一查询语句，同时返回查询结果数目
/// </summary>
/// <param name="strSQL"></param>
/// <returns></returns>
public int ReturnSqlResultCount(string strSQL)
{
    int sqlResultCount = 0;

    try
    {
        Connection.Open();
        OleDbCommand command = new OleDbCommand(strSQL, Connection);
        OleDbDataReader dataReader = command.ExecuteReader();

        while (dataReader.Read())
        {
            sqlResultCount++;
        }
        dataReader.Close();
    }
    catch
    {
        sqlResultCount = 0;
    }
    finally
    {
        Connection.Close();
    }
    return sqlResultCount;
}