Расскажу все сначала. Имеется БД в Access
(
24 таблицы,
все теблицы имеют ключ - поле с именем ID (Autoincrement),
все таблицы связаны друг с другом (каскадное удаление/обновление)
)
В приложении (WinForms) я хочу загузить всю БД из файла в DataSet поработать с DataSet'ом и сохранить изменения обратно в файл (структура DataSet'а полностью такая же как и у оригинальной БД - со всеми связями и ключами).
БД из файла в ДатаСет гружу следующим образом:
открываю соединение,
каждая таблица загружается отдельно своим ДатаАдаптером,
для каждого ДатаАдаптера создается КоммандБилдер,
подписываюсь на RowUpdated Адаптера, чтобы корректировать поле ID, когда таблица будет обновляться обратно в БД
ДатаАдаптер сохраняется в хеш-массиве (чтобы использовать его же затем для вызова метода Update() для данной теблицы)
закрываю соединение.
ДатаСет в БД пытаюсь сохранить следующим образом:
открываю соединение,
Для всех таблиц:
{
получаю изменения, внесенные в Датасет
отыскиваю в хеш-массиве по имени таблицы нужный ДатаАдаптер,
вызываю Update() найденного Адаптера,
}
закрываю соединение.
Проблема: например, при добавлении трех записей в еще пустую таблицу ДатаСета он генерирует для записей следующие ID:
0
1
2
Пытаюсь передать изменения в Аксесс. Передается первая строка, но Аксесс сам для нее сгенерирует ID, равное 1 (а не 0, как до этого сгенерировал ДатаСет). Пытаюсь вернуть ID, сгенерированное Аксессом в Датасет (в обработчике события RowUpdated() запрашивается @@IDENTITY):
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
private static void OnRowUpdated(object sender, OleDbRowUpdatedEventArgs args)
{
// Include a variable and a command to retrieve the identity value from the Access database.
int newID = 0 ;
OleDbCommand idCMD = new OleDbCommand("SELECT @@IDENTITY", odcConn);
if (args.StatementType == StatementType.Insert)
{
// Retrieve the identity value and store it in the ID column.
newID = (int) idCMD.ExecuteScalar();
args.Row["ID"] = newID;
}
}
но когда программа доходит до строки
args.Row["ID"] = newID;
генерируется исключение, т.к. в ДатаСете уже существует поле ID со значением 1
Собственно вопрос : как с этим бороться?????
Сам подход для работы с БД верно выбран??? (то, что я загружаю в ДатаСет ВСЮ БД??? то, что БД загружается отдельно по табличкам???)
Класс для работы с Датасетом приведен ниже (здесь грузятся не все таблицы из БД, а только четыре).
Для доступа к ДатаСету нужно из программы обратится к полю CDBMan.Instance.dstbData - если ДатаСет уже заполнен, то получаем ссылку на него, если еще не заполнен, то создается новый и заполняется.
Для записи изменений обратно в БД - метод CDBMan.vUpdate()
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
120.
121.
122.
123.
124.
125.
126.
127.
128.
129.
130.
131.
132.
133.
134.
135.
136.
137.
138.
139.
140.
using System;
using System.Data;
using System.Data.OleDb;
using System.Collections;
using System.Windows.Forms;
namespace TestBed2006
{
/// <summary>
/// Summary description for CDBMan.
/// </summary>
public class CDBMan
{
private static object lockFlag = new object();
private static CDBMan instance;
private static string sconnectionstring =
"Jet OLEDB:Global Partial Bulk Ops=2;" +
"Jet OLEDB:Registry Path=;" +
"Jet OLEDB:Database Locking Mode=1;" +
"Data Source=\"D:\\ArtemK\\Projects\\TestBed\\Data\\TestBed2006.mdb\";" + "Mode=Share Deny None;" +
"Jet OLEDB:Engine Type=5;" +
"Provider=\"Microsoft.Jet.OLEDB. 4 . 0 \";" +
"Jet OLEDB:System database=;" +
"Jet OLEDB:SFP=False;" +
"persist security info=False;" +
"Extended Properties=;" +
"Jet OLEDB:Compact Without Replica Repair=False;" +
"Jet OLEDB:Encrypt Database=False;" +
"Jet OLEDB:Create System Database=False;" +
"Jet OLEDB:Don't Copy Locale on Compact=False;" +
"User ID=Admin;Jet OLEDB:Global Bulk Transactions=1";
private static OleDbConnection odcConn = new OleDbConnection(sConString);
private static Hashtable htAdapters = new Hashtable();
public dsTestBed2006 dstbData = new dsTestBed2006();
public static string sConString
{
get
{
return sconnectionstring;
}
set
{
sconnectionstring = value;
vReload();
}
}
public static void vReload()
{
instance = null;
}
private static void vFillTable(string sTblName)
{
OleDbDataAdapter oddaAdapt = new OleDbDataAdapter();
oddaAdapt.SelectCommand = new OleDbCommand("select * from " + sTblName, odcConn);
OleDbCommandBuilder odcbBuilder = new OleDbCommandBuilder(oddaAdapt);
oddaAdapt.Fill(instance.dstbData.Tables[sTblName]);
oddaAdapt.RowUpdated += new OleDbRowUpdatedEventHandler(OnRowUpdated);
htAdapters.Add(sTblName, oddaAdapt);
}
private static void vUpdateTable(string sTblName)
{
DataSet dsTmp = instance.dstbData.GetChanges();
if (dsTmp != null)
{
OleDbDataAdapter oddaAdapt = (OleDbDataAdapter) htAdapters[sTblName];
oddaAdapt.Update(dsTmp.Tables[sTblName]);
}
}
private static void OnRowUpdated(object sender, OleDbRowUpdatedEventArgs args)
{
// Include a variable and a command to retrieve the identity value from the Access database.
int newID = 0 ;
OleDbCommand idCMD = new OleDbCommand("SELECT @@IDENTITY", odcConn);
if (args.StatementType == StatementType.Insert)
{
// Retrieve the identity value and store it in the ID column.
newID = (int) idCMD.ExecuteScalar();
args.Row["ID"] = newID;
}
}
public static void vUpdate()
{
lock(lockFlag)
{
if(instance != null)
{
odcConn.Open();
vUpdateTable("TesterCategory");
vUpdateTable("TesterExemplar");
vUpdateTable("SysPower");
vUpdateTable("SysAnlComm");
odcConn.Close();
}
}
}
public static CDBMan Instance
{
get
{
lock(lockFlag)
{
if(instance == null)
{
instance = new CDBMan();
odcConn = new OleDbConnection(sConString);
odcConn.Open();
vFillTable("TesterCategory");
vFillTable("TesterExemplar");
vFillTable("SysPower");
vFillTable("SysAnlComm");
odcConn.Close();
}
}
return instance;
}
}
}
}
