我是个新手。
请大家 帮忙指点。程序的目的:
从interbase库中查询出记录,插入另一台服务器的oracle库中,要求使用dataset。现在程序显示“插入成功!”catch(Exception)没有异常,但是oracle库中没有新增记录。求大家 帮忙指点。
先谢了!string Connstr1 = "interbase连接字符串";
Borland.Data.Provider.BdpConnection conn1 = new Borland.Data.Provider.BdpConnection(Connstr1);
conn1.Open();
string sql1 = "Select * from KUANG_XYTZ1 where CHECI=2";
Borland.Data.Provider.BdpDataAdapter adapter1 = new Borland.Data.Provider.BdpDataAdapter(sql1,conn1);
System.Data.DataSet ds1 = new DataSet();
adapter1.Fill(ds1,"KUANG_XYTZ1");
conn1.Close();string Connstr = "oracle连接字符串";
System.Data.OracleClient.OracleConnection conn = new OracleConnection(Connstr);
conn.Open();
System.Data.OracleClient.OracleDataAdapter adapter = new OracleDataAdapter("",conn);
adapter.SelectCommand.CommandText = "Select * from ORACLE_XYTZ";
System.Data.OracleClient.OracleCommandBuilder builder = new OracleCommandBuilder(adapter);
System.Data.DataSet ds = new DataSet();
adapter.Fill(ds,"ORACLE_XYTZ");
DataTable table = ds.Tables["ORACLE_XYTZ"];
ds.Merge(ds1);
adapter.Update(table);
conn.Close();
请大家 帮忙指点。程序的目的:
从interbase库中查询出记录,插入另一台服务器的oracle库中,要求使用dataset。现在程序显示“插入成功!”catch(Exception)没有异常,但是oracle库中没有新增记录。求大家 帮忙指点。
先谢了!string Connstr1 = "interbase连接字符串";
Borland.Data.Provider.BdpConnection conn1 = new Borland.Data.Provider.BdpConnection(Connstr1);
conn1.Open();
string sql1 = "Select * from KUANG_XYTZ1 where CHECI=2";
Borland.Data.Provider.BdpDataAdapter adapter1 = new Borland.Data.Provider.BdpDataAdapter(sql1,conn1);
System.Data.DataSet ds1 = new DataSet();
adapter1.Fill(ds1,"KUANG_XYTZ1");
conn1.Close();string Connstr = "oracle连接字符串";
System.Data.OracleClient.OracleConnection conn = new OracleConnection(Connstr);
conn.Open();
System.Data.OracleClient.OracleDataAdapter adapter = new OracleDataAdapter("",conn);
adapter.SelectCommand.CommandText = "Select * from ORACLE_XYTZ";
System.Data.OracleClient.OracleCommandBuilder builder = new OracleCommandBuilder(adapter);
System.Data.DataSet ds = new DataSet();
adapter.Fill(ds,"ORACLE_XYTZ");
DataTable table = ds.Tables["ORACLE_XYTZ"];
ds.Merge(ds1);
adapter.Update(table);
conn.Close();
着急 都乱了。
//假设dt1是IB的,dt2是Oracle的,两个DataTable的获取方法你写的那段就行。
foreath(DataRow dr in dt1.Rows)
{
DataRow newdr = dt2.NewRow();
newdr["col1"] = dr["col1"];
...
dt2.Rows.Add(newdr);
}
adapter.Update(dt2);
好象oracle的conn需要commit才能真正修改数据库