Обновить и вставить записи в таблицу Oracle, используя OracleDataAdapter от DataTable ⇐ C#

[Anonymous]

Вопрос от новичка до C# и извинения за это. У меня есть следующий сценарий. У меня есть небольшое приложение для консоли, которое заполняет DataTable, подключаясь к внешней системе, а затем нужно обновить существующие записи и вставить новые в таблицу Oracle. Столбцы в данных не называются такими же, как столбцы таблицы Oracle, а не в том же порядке. Я прочитал еще один пост здесь с аналогичным сценарием (загрузка из файла в таблицу), и он упомянул, что выполнение обновления/вставки с помощью OracledataAdapter будет работать. Упрощенная таблица данных и Oracle - < /p>

DataTable table = new DataTable();
table.Columns.Add("Product", typeof(String));
table.Columns.Add("Price", typeof(double));
table.Columns.Add("Effective_Date", typeof(DateTime));< /code> < /p>

//sample data
table.Rows.Add("abcd", 1.011, DateTime.Today);
table.Rows.Add("efg", 1.00, DateTime.Today);
table.Rows.Add("hijk", 20, DateTime.Today);< /code> < /p>

The oracle table has the structure

ITEM VARCHAR2(20 BYTE) NOT NULL ENABLE,
EFF_DATE DATE,
VALUE NUMBER< /code> < /p>

I have tried the following code to use the datatable and an adapter to update the oracle table but I'm missing something. I'm also wondering if I'm barking up the wrong tree. The majority of examples I have seen of using a dataadapter first does a select from the table and then puts the results into a grid where a user would be able to add, update, insert, or delete records and then uses the dataadapter to update the table. In my case I'm wondering if I get it to work if all records in the datatable will be treated as an insert anyway as there is no connection between the datatable and the oracle table.

I'm using the Oracle.ManagedDataAccess.Client to connect and do the updates

public static void UpdateOrSaveItems(DataTable dt)
{
String insert_statement, update_statement, select_statement;

select_statement = "SELECT * from items";
insert_statement = "INSERT INTO items (item, eff_date, value) values (:pInsItem,:pInsEffDate,:pInsValue)";
update_statement = "UPDATE items set eff_date = :pUpdEffDate, value = :pUpdValue where item = :pUpdItem";

using (OracleConnection conn = theDatabase.ConnectToDatabase())
{
using (OracleDataAdapter oraAdapter = new OracleDataAdapter(select_statement, conn))
{

//build update/insert commands and parameters
oraAdapter.UpdateCommand = new OracleCommand(update_statement, conn);
oraAdapter.InsertCommand = new OracleCommand(insert_statement, conn);

oraAdapter.UpdateCommand.BindByName = true;
oraAdapter.InsertCommand.BindByName = true;

OracleParameter pUpdItem = new OracleParameter("pUpdItem", OracleDbType.Varchar2);
pUpdItem.SourceColumn = dt.Columns[0].ColumnName;

OracleParameter pUpdEffDate = new OracleParameter("pUpdEffDate", OracleDbType.Date);
pUpdEffDate.SourceColumn = dt.Columns[2].ColumnName;

OracleParameter pUpdValue = new OracleParameter("pUpdValue", OracleDbType.Double);
pUpdValue.SourceColumn = dt.Columns[1].ColumnName;

OracleParameter pInsItem = new OracleParameter("pInsItem", OracleDbType.Varchar2);
pUpdItem.SourceColumn = dt.Columns[0].ColumnName;

OracleParameter pInsEffDate = new OracleParameter("pInsEffDate", OracleDbType.Date);
pInsEffDate.SourceColumn = dt.Columns[2].ColumnName;

OracleParameter pInsValue = new OracleParameter("pInsValue", OracleDbType.Double);
pInsValue.SourceColumn = dt.Columns[1].ColumnName; oraAdapter.UpdateCommand.Parameters.Add(pUpdItem);

oraAdapter.UpdateCommand.Parameters.Add(pUpdEffDate);
oraAdapter.UpdateCommand.Parameters.Add(pUpdValue);

oraAdapter.InsertCommand.Parameters.Add(pInsItem);
oraAdapter.InsertCommand.Parameters.Add(pInsEffDate);
oraAdapter.InsertCommand.Parameters.Add(pInsValue);

oraAdapter.Update(dt);
}
}
}
< /code>

Когда я запускаю это, я получаю ошибку, которая не могу вставить нуль в столбец, который определяется как ключ. В данных ни один из них не является нулевым. Я что -то упускаю в том, чтобы рассказать о том, где данные, но я не уверен, что это такое. Также интересно, правильный ли это способ сделать такие вещи. Я хотел избежать < /p>

loop through datatable
select to see if record is in oracle table
if in table update else insert< /code> < /p>

because the volume of records could a couple of hundred thousand and wasn't sure what the performance would be like.

Подробнее здесь: https://stackoverflow.com/questions/230 ... om-datatab