【发布时间】：2014-03-05 10:16:20
【问题描述】：
我需要将一些 CSV 文件导入到 MDB 数据库中的临时表中。 这些文件来自 ASP.NET Web 应用程序上的文件上传。
这是我的 CSV 文件：
"Operating Unit Organization Name";"Year";"Sales Rep Name";"Date";"Week";"Product Number";"Account Name";"Customer Number";"Corporate Brand";"Brand";"Ordered Quantity";"Amount"
"IT Operating Unit";2014;"Name-561004";2014-02-21;"2014 Week08";"123456+";"Buyer name";"456789";"Corp Brand";"Brand";4;147,52
"IT Operating Unit";2014;"Name-561004";2014-02-21;"2014 Week08";"123.012EXP";"Buyer name";"789123";"Corp Brand";"Brand";10;204,9
"IT Operating Unit";2014;"Name-561004";2014-02-17;"2014 Week08";"101S-3";"Buyer name";"234567";"Another Corp Brand";"Another Brand";30;237,5
这是生成schema.ini 文件的方法。由于它必须包含 CSV 文件的名称，因此我每次上传新的 CSV 时都会生成一个新的架构文件，因为我需要将它们全部保存在具有特定名称的文件夹中。
private void CreateCsvSchemaFile()
{
using (FileStream fs = new FileStream(Path.GetDirectoryName(FilePath) + "\\schema.ini", FileMode.Create, FileAccess.Write))
{
using (StreamWriter sw = new StreamWriter(fs))
{
sw.WriteLine("[" + Path.GetFileName(FilePath) + "]");
sw.WriteLine("ColNameHeader=True");
//sw.WriteLine("MaxScanRows=0");
sw.WriteLine("Format=Delimited(;)");
sw.WriteLine("DateTimeFormat=yyyy-MM-dd");
sw.WriteLine("CharacterSet=ANSI");
sw.WriteLine("DecimalSymbol=,");
sw.WriteLine("Col1=\"Operating Unit Organization Name\" Text Width 255");
sw.WriteLine("Col2=\"Year\" Long");
sw.WriteLine("Col3=\"Sales Rep Name\" Text Width 255");
sw.WriteLine("Col4=\"Date\" DateTime");
sw.WriteLine("Col5=\"Week\" Text Width 255");
sw.WriteLine("Col6=\"Product Number\" Text Width 255");
sw.WriteLine("Col7=\"Account Name\" Text Width 255");
sw.WriteLine("Col8=\"Customer Number\" Text Width 255");
sw.WriteLine("Col9=\"Corporate Brand\" Text Width 255");
sw.WriteLine("Col10=\"Brand\" Text Width 255");
sw.WriteLine("Col11=\"Ordered Quantity\" Long");
sw.WriteLine("Col12=\"Amount\" Currency");
sw.Close();
sw.Dispose();
}
fs.Close();
fs.Dispose();
}
}
schema.ini 文件始终正确生成，实际上数据库上的表是使用正确的字段名称和类型创建的。
这是执行 CSV 导入的方法。
private void ImportCsvIntoTemp()
{
try
{
CreateCsvSchemaFile();
string query = @"SELECT * INTO TEMP_CSV
FROM [Text;HDR=no;Database={0}].[{1}]";
query = String.Format(query, Path.GetDirectoryName(FilePath), Path.GetFileName(FilePath));
AccessDb.Query(AccessDbConnString, query);
}
catch (Exception ex)
{
string message = String.Format("CSV file import failed. Inner Exception: {0}", ex.Message);
throw new ImportFailedException(message);
}
}
表TEMP_CSV 已正确创建但未加载任何数据。
相反，如果我使用 Access 打开 MDB，我会看到 8 个空行。我尝试更改schema.ini 文件上的一些参数，例如添加/删除MaxScnaRows=0、CharacterSet 等等...在查询中我也尝试更改FROM Properties，但我总是得到同样的结果。
-- EDIT 添加了AccessDb.Query() 方法 和数据库连接字符串--
我没有包含Query() 方法，因为AccessDb 它只是一个“数据库层”类，其中包含创建与数据库的连接并执行带/不带参数的查询/列表查询/标量的方法。我在其他页面和许多其他应用程序中使用这个类。
不管怎样，这是AccessDb.Query()方法。
public static void Query(string connString, string query)
{
OleDbConnection conn = new OleDbConnection(connString);
try
{
conn.Open();
OleDbCommand cmd = conn.CreateCommand();
cmd.CommandText = query;
cmd.ExecuteNonQuery();
cmd.Dispose();
}
catch (OleDbException odbEx)
{
throw odbEx;
}
catch (Exception ex)
{
throw ex;
}
finally
{
conn.Dispose();
conn.Close();
}
}
这是我的数据库连接字符串，在Web.config 文件中配置。
<connectionStrings>
<add name="DefaultConnection" providerName="System.Data.OleDb" connectionString="Provider=Microsoft.Jet.OLEDB.4.0;Data Source=D:\Progetti\Personale\Progetti\Infomed\Database\Infomed.mdb;User Id=admin;Password=;" />
</connectionStrings>
【问题讨论】：
-
您添加的代码很有帮助，但我们仍然不知道您的
connString是什么样的。 -
添加了连接字符串！