DataTable의 데이터를 데이터베이스에 한번에 삽입하기 위한 C# 샘플 코드에 대한 자세한 설명

이 글에서는 C#DataTable의 데이터를 데이터 라이브러리에 한 번에 삽입하는 자세한 방법을 소개합니다. 관심 있는 분들은 참고할 만한 가치가 있습니다.

현재 실제 상황은 다음과 같습니다.

고객은 출근 기계를 가지고 있으며 모든 직원 출근 정보는 출근 기계의 Access 데이터베이스에 저장됩니다. 고객이 새로운 관리 시스템을 도입했기 때문에 오랜 시간 동안 400,000개 이상의 데이터가 축적되어 Access 데이터베이스의 펀치인 데이터를 SQL Server 데이터베이스에 동기화해야 합니다.

소프트웨어 기능:

Access 데이터베이스 파일을 선택하고 대상 SQL Server 데이터베이스의 IP 주소를 입력한 다음 동기화를 시작합니다.

구현 방법:

1. 먼저 Access 데이터베이스에서 가져올 데이터를 DataTable에 저장합니다.

구성 파일에 데이터베이스 연결 String

<connectionStrings>
  <add name="oleConStr" connectionString="Provider=Microsoft.Jet.OLEDB.4.0;Data Source="/>
  
  <add name="sqlConStr" connectionString ="server=tiantiankaixing;database=新建数据库;trusted_connection=sspi"/>
 </connectionStrings>

Access 데이터베이스 데이터를 DataTable로 읽는 방법을 캡슐화합니다.

public static string OleConStr = ConfigurationManager.ConnectionStrings["oleConStr"].ConnectionString ;

 public static DataTable OleGetDataTable(string sql, string filePath)
    {
      
      string a = OleConStr + filePath;
      using (OleDbConnection conn = new OleDbConnection(a))
      {

        using (OleDbDataAdapter da = new OleDbDataAdapter(sql, conn))
        {
          try
          {
            conn.Open();
            DataTable dt = new DataTable();
            da.Fill(dt);
            return dt;
          }
          catch (Exception ex)
          {
            throw ex;
          }
          finally
          {
            if (conn.State == ConnectionState.Open)
              conn.Close();
          }
        }
      }
    }

대상 Access 데이터베이스를 Datatable로 읽어옵니다

string sql = "select Id,Time from checkinout";
DataTable dt = AcHelper.OleGetDataTable(sql, @"F:\project\tiantiankaixing\admin.mdb");

2. 데이터 SQL Server 데이터 메소드

public static void DataTableToSQLServer(DataTable dt,string connectString)
    {
      string connectionString = connectString;

      using (SqlConnection destinationConnection = new SqlConnection(connectionString))
      {
        destinationConnection.Open();

        using (SqlBulkCopy bulkCopy = new SqlBulkCopy(destinationConnection))
        {


          try
          {

            bulkCopy.DestinationTableName = "checkinout";//要插入的表的表名
            bulkCopy.BatchSize = dt.Rows.Count;
            bulkCopy.ColumnMappings.Add("ID", "ID");//映射字段名 DataTable列名 ,数据库 对应的列名 
            bulkCopy.ColumnMappings.Add("TIME", "TIME");
            
            bulkCopy.WriteToServer(dt);
            System.Windows.Forms.MessageBox.Show("插入成功");
          }
          catch (Exception ex)
          {
            Console.WriteLine(ex.Message);
          }
          finally
          {
            

          }
        }


      }

    }

3. DataTableToSQlServer() 메소드

string localCon = "server=tiantiankaixing;database=Test;trusted_connection=sspi";
Entity.DataTableToSQLServer(dt, localCon);

를 호출하여 DataTable의 모든 데이터를 데이터베이스에 삽입합니다

첨부: SqlBulkCopy의 간단한 사용법

아아아아

위 내용은 DataTable의 데이터를 데이터베이스에 한번에 삽입하기 위한 C# 샘플 코드에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!