将sqlserver中数据导入到oracle数据中

以下贴出部分代码：C#

需要引用

using System.Data.OracleClient;

using System.Data.SqlClient;

private void button3_Click(object sender, EventArgs e) //将sqlserver中数据导入到oracle数据中

{

button3.Enabled = false; //防止多次点击

int temp=0; //用于判断插入是否成功

string sqlstr; //接收插入语句

DataTable dt = new DataTable();

string sql = "select * from dictionary"; // oracle中已存在的数据表

Sqldataload sqldata = new Sqldataload(); //自定义类

dt = sqldata.ORselect(sql);

string[] col = new string[3]; //用于接收没一行中的数据

if (dt.Rows.Count > 0)

{

for (int i = 0; i < dt.Rows.Count; i++) //循环每一行

{

for (int j = 0; j < dt.Columns.Count; j++) //循环每一列

{

col[j] = dt.Rows[i][j].ToString();

}

sqlstr = "Insert into Tdictionary(EnField,ChField,Method) values(" + StrTo(col[0]) + "," + StrTo(col[1]) + "," + StrTo(col[2]) + ")";

Dataconn ORconn = new Dataconn();

temp = ORconn.ORUpdate(sqlstr); //将数据插入到oracle数据中

}

}

button3.Enabled = true;

if (temp!=-1) MessageBox.Show("转换成功！！");

else

MessageBox.Show("转换失败！！");

}

public string StrTo(string str)

{

str = "'" + str + "'";

return str;

}

自定义类：

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data.OracleClient;

using System.Data;

namespace ExceltoOracleTable

{

class Dataconn

{

public Dataconn()

{

}

public string ConnectionString = "Data Source=telecom;Persist Security Info=True;User ID=qiao;Password=qiao;Unicode=True"; //写连接串

public DataTable ORselect(string str)

{

DataTable dt = new DataTable();

OracleConnection conn = new OracleConnection();

conn.ConnectionString = ConnectionString;

OracleDataAdapter adapter = new OracleDataAdapter(str, conn);

try

{

conn.Open();

adapter.Fill(dt);

}

catch (OracleException ee)

{

}

finally

{

conn.Close(); //关闭连接

}

return dt;

}

public int ORUpdate(string SQLstr)

{

OracleConnection conn = new OracleConnection();

conn.ConnectionString = ConnectionString;

OracleCommand command = new OracleCommand(SQLstr, conn);

try

{

conn.Open();

return command.ExecuteNonQuery(); //返回操作行数

}

catch (OracleException ee)

{

return -1; //操作失败

}

finally

{

conn.Close(); //关闭连接

}

}

public DataSet ORSelect2(string str)

{

OracleConnection conn = new OracleConnection();

conn.ConnectionString = ConnectionString;

OracleDataAdapter adapter = new OracleDataAdapter(str, conn);

DataSet DS = new DataSet();

try

{

conn.Open();

adapter.Fill(DS );

}

catch (OracleException ee)

{

// messagebox.show("连接失败！！！");

}

finally

{

conn.Close(); //关闭连接

}

return DS;

}

}

}