public void InsertDataToOracle(string strTableName)
{
DataSet dsSrc = new DataSet();
dsSrc = GetDataByTableName(strTableName);
dsSrc.Tables[0].TableName = "qx_ry";
string sql = "Select id, rybh, rymc, dlmc from ZCF_ry";
OracleConnection cn = new OracleConnection("Data Source=kfbzcf;User Id=zcf;Password=zcf"); // 注意连接字符串
OracleDataAdapter da = new OracleDataAdapter(sql, cn);
DataSet ds = new DataSet();
try
{
cn.Open();
da.Fill(ds, "ZCF_ry");
}
finally
{
cn.Close();
}
//向ds中追加要添加的批量数据
DataRow dr;
for (int i = 0; i < dsSrc.Tables[0].Rows.Count; i++)
{
dr = ds.Tables["ZCF_ry"].NewRow();
dr["id"] = dsSrc.Tables[0].Rows[i][0].ToString();
dr["rybh"] = dsSrc.Tables[0].Rows[i][1].ToString();
dr["rymc"] = dsSrc.Tables[0].Rows[i][2].ToString();
dr["dlmc"] = dsSrc.Tables[0].Rows[i][6].ToString();
ds.Tables["ZCF_ry"].Rows.Add(dr);
本内容试读结束,登录后可阅读更多
下载后可阅读完整内容,剩余2页未读,立即下载