2

我有 CSV 文件，其中有几个数据列。

CSV 文件看起来像

字段 1：测试 1
字段 2：测试 2
字段 3：测试 3、测试 4、测试 5

在这种情况下，我可以使用哪个库作为字段终止符我的意思是如果我使用此查询将 CSV 文件插入shopifyitem表中，因为您假设插入的数据字段不正确 

BULK INSERT shopifyitem
FROM 'c:\test.csv'
WITH
(
   FIELDTERMINATOR = ',',
   ROWTERMINATOR = '\n'
)

那么我可以使用哪个字段终止符？

非常感谢您提前......

4

4 回答 4

1

尝试使用：
ROWTERMINATOR = '0x0a'

于 2014-01-16T12:39:08.977 回答
1

我认为如果没有某种类型的预处理，您将无法导入该格式。正如 Aaron 暗示的那样，这不是标准的 CSV。

如果您无法重新格式化文件，有几种方法可以将数据转换为可导入的格式：

http://www.timmitchell.net/post/2013/01/14/ragged-flat-file-processing-in-ssis/

http://www.rad.pasfu.com/index.php?/archives/38-Script-Component-as-Source-SSIS.html

http://msdn.microsoft.com/en-us/library/ms136060.aspx（向下滚动到“平面文件源示例”）

这些都是利用 .NET 完成大部分工作的 SSIS 解决方案。我更喜欢 SSIS 仅仅是因为内置的生产力工具。它可以使用任何文本处理器来完成，例如控制台应用程序或 powershell 脚本（如果您真的有时间的话）。

我更喜欢带有流阅读器的脚本组件源，但 Tim Mitchell 有一个有趣的替代方案。

于 2013-01-30T03:04:13.907 回答
0

这是将文本或 csv 文件导入数据库的代码：

String SQL = "BULK INSERT [staging_db].[dbo].[TEST] FROM 'D:\\test.txt' WITH (FIELDTERMINATOR = ',',ROWTERMINATOR = '\n')";
于 2013-06-17T12:09:09.550 回答
0 
using System;
using System.Data;
using System.Data.SqlClient;

namespace SqlBulkInsertExample
{
    class Program
    {
      static void Main(string[] args)
        {
            DataTable prodSalesData = new DataTable("ProductSalesData");

            // Create Column 1: SaleDate
            DataColumn dateColumn = new DataColumn();
            dateColumn.DataType = Type.GetType("System.DateTime");
            dateColumn.ColumnName = "SaleDate";

            // Create Column 2: ProductName
            DataColumn productNameColumn = new DataColumn();
            productNameColumn.ColumnName = "ProductName";

            // Create Column 3: TotalSales
            DataColumn totalSalesColumn = new DataColumn();
            totalSalesColumn.DataType = Type.GetType("System.Int32");
            totalSalesColumn.ColumnName = "TotalSales";

            // Add the columns to the ProductSalesData DataTable
            prodSalesData.Columns.Add(dateColumn);
            prodSalesData.Columns.Add(productNameColumn);
            prodSalesData.Columns.Add(totalSalesColumn);

            // Let's populate the datatable with our stats.
            // You can add as many rows as you want here!

            // Create a new row
            DataRow dailyProductSalesRow = prodSalesData.NewRow();
            dailyProductSalesRow["SaleDate"] = DateTime.Now.Date;
            dailyProductSalesRow["ProductName"] = "Nike";
            dailyProductSalesRow["TotalSales"] = 10;

            // Add the row to the ProductSalesData DataTable
            prodSalesData.Rows.Add(dailyProductSalesRow);

            // Copy the DataTable to SQL Server using SqlBulkCopy
            using (SqlConnection dbConnection = new SqlConnection("Data Source=ProductHost;Initial Catalog=dbProduct;Integrated Security=SSPI;Connection Timeout=60;Min Pool Size=2;Max Pool Size=20;"))
            {
                dbConnection.Open();
                using (SqlBulkCopy s = new SqlBulkCopy(dbConnection))
                {
                    s.DestinationTableName = prodSalesData.TableName;

                    foreach (var column in prodSalesData.Columns)
                        s.ColumnMappings.Add(column.ToString(), column.ToString());

                    s.WriteToServer(prodSalesData);
                }
            }
        }
    }
}
于 2013-08-30T04:24:04.217 回答