using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Data.OleDb;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using Oracle.ManagedDataAccess.Client;
namespace excel表匯入oracle
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}
private void button1_Click(object sender, EventArgs e)
{
OpenFileDialog openFileDialog1 = new OpenFileDialog();
openFileDialog1.Filter = "電子表格(*.xls)|*.xlsx";
openFileDialog1.ShowDialog();//打開對話框
this.textBox1.Text = openFileDialog1.FileName;//得到檔案=路徑+名稱
}
private void button2_Click(object sender, EventArgs e)
{
try
{
DataSet ds = ImportExcel(this.textBox1.Text);//將excel的物件先放到ds 中
if (ds != null)
{
if (ds.Tables[0].Rows.Count > 0)//如果ds中是有值的話 執行下面的操作
{
if (ExportInfo(ds))
{
MessageBox.Show("匯入資料庫成功!");
}
else
{
MessageBox.Show("匯入資料庫失敗!");
}
}
}
}
catch
{
MessageBox.Show("匯入資料庫失敗 請檢查匯入檔案是否填寫正確!");
}
}
public static DataSet ImportExcel(string file)
{
FileInfo fileInfo = new FileInfo(file);
if (!fileInfo.Exists) return null; string strConn = "Provider=Microsoft.Ace.OleDb.12.0;" + "data source=" + file + ";Extended Properties='Excel 12.0; HDR=Yes; IMEX=1'";
OleDbConnection objConn = new OleDbConnection(strConn);
DataSet dsExcel = new DataSet();
try
{
objConn.Open();
string strSql = "select * from [Sheet1$]";
OleDbDataAdapter odbcExcelDataAdapter = new OleDbDataAdapter(strSql, objConn);
odbcExcelDataAdapter.Fill(dsExcel); return dsExcel;
}
catch (Exception ex)
{
throw ex;
}
}
/// <summary>
/// 這是將ds物件匯入資料庫的方法
/// 代云超
/// </summary>
/// <returns>執行是否成功 如: 成功=true 失敗=false</returns>
public static bool ExportInfo(DataSet ds)
{
if (ds != null)
{
if (ds.Tables[0].Rows.Count > 0)//如果ds中是有值的話 執行下面的操作
{
return Do(ds);//執行成功
}
}
return false;//執行失敗
}
public static bool Do(DataSet ds)
{
OracleConnection conNorthwind = new OracleConnection("Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=127.0.0.1)(PORT=1521))(CONNECT_DATA=https://bbs.csdn.net/topics/(SERVICE_NAME=orcl)));Persist Security Info=True;User ID=system;Password=orcl;");//鏈接字串
OracleCommand commandNorthwind = new OracleCommand();
try
{
conNorthwind.Open();//打開資料庫鏈接
OracleTransaction tranNorthwind = conNorthwind.BeginTransaction();//開始事務
Console.WriteLine("行數"+ds.Tables[0].Rows.Count);
for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
{
DataRow dr = ds.Tables[0].Rows[i];
OracleParameter[] parameters = null;//為了得到插入資料庫的引數 定義引數物件 為空
string sql = GetSqlString(dr, out parameters);//執行sql -->用out關鍵字得到引數 賦到parameters物件上
//插入資料庫中
PrepareCommand(commandNorthwind, conNorthwind, tranNorthwind, sql, parameters);
Console.WriteLine("liyaxuan測驗儀"+ sql.ToString());
int a= commandNorthwind.ExecuteNonQuery();//執行操作
Console.WriteLine(a);
}
commandNorthwind.Transaction.Commit();//提交事務
conNorthwind.Close();//關閉資料庫鏈接資源
return true;
}
catch//如果有例外 不一定要捕捉例外 但要rollback事務
{
if (commandNorthwind.Transaction != null && conNorthwind != null)
{
commandNorthwind.Transaction.Rollback();//rollback事務
conNorthwind.Close();//關閉資料庫鏈接
}
return false;
}
}
/// <summary>
/// 每一行資訊插入資料庫中
/// </summary>
/// <param name="dr">要插入的這一行ds-datarow物件</param>
/// <returns>sql陳述句和用out關鍵字的引數陣列物件</returns>
public static string GetSqlString(DataRow dr, out OracleParameter[] parameters)
{
StringBuilder sb = new StringBuilder();
sb.Append("INSERT INTO LIYAXUAN.TEXT(ID,NAME) VALUES(:ID,:NAME)");
parameters = new OracleParameter[] { new OracleParameter(":ID", Convert.ToString(dr[0])), new OracleParameter(":NAME", Convert.ToString(dr[1])) };
Console.WriteLine("ID的值"+ dr[0]);
Console.WriteLine("name的值" + dr[1]);
return sb.ToString();//將sqlreturn出去
}
private static void PrepareCommand(OracleCommand cmd, OracleConnection conn, OracleTransaction trans, string cmdText, OracleParameter[] cmdParms)
{
PrepareCommand(cmd, conn, trans, cmdText, CommandType.Text, cmdParms);
}
//引數設定 此方法被多載
private static void PrepareCommand(OracleCommand cmd, OracleConnection conn, OracleTransaction trans, string cmdText, CommandType cmdType, OracleParameter[] cmdParms)
{
if (conn.State != ConnectionState.Open)
{
conn.Open();
}
cmd.Connection = conn;
cmd.CommandText = cmdText;
if (trans != null)
{
cmd.Transaction = trans;
}
cmd.CommandType = cmdType; // CommandType.Text;//cmdType;
if (cmdParms != null)
{
foreach (OracleParameter parameter in cmdParms)
{
if (parameter != null)
{
if (parameter.Value == null)
{
parameter.Value = DBNull.Value;
}
cmd.Parameters.Add(parameter);
Console.WriteLine("parameter:" + parameter);
}
}
}
}
}
}
uj5u.com熱心網友回復：
具體的報錯位置呢？uj5u.com熱心網友回復：
commandNorthwind.ExecuteNonQuery();//執行操作 是這句話uj5u.com熱心網友回復：
當Excel有一條是不會出錯，都是從第二次報的錯誤uj5u.com熱心網友回復：
看看前邊的是不是有變數為null，且這個null是不是不被允許的。
uj5u.com熱心網友回復：
我就是看不出來才來問的啊5555，第一行匯入沒問題，從第二行有問題uj5u.com熱心網友回復：
斷點進去看看啊。uj5u.com熱心網友回復：
斷了 在這一行commandNorthwind.ExecuteNonQuery();//執行操作 說未將物件參考設定到物件的實體uj5u.com熱心網友回復：
這幾個引數，滑鼠移上去看看。
PrepareCommand(commandNorthwind, conNorthwind, tranNorthwind, sql, parameters);
uj5u.com熱心網友回復：
沒看出來啥問題啊，里面都有啊uj5u.com熱心網友回復：
commandNorthwind.ExecuteNonQuery();//執行操作 是這句話uj5u.com熱心網友回復：
足部斷電無法找到問題嗎？轉載請註明出處，本文鏈接：https://www.uj5u.com/net/24483.html
標籤：C#