80 |
80 |
bool result = false;
|
81 |
81 |
ID2Info id2Info = ID2Info.GetInstance();
|
82 |
82 |
|
83 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
83 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
84 |
84 |
{
|
85 |
85 |
try
|
86 |
86 |
{
|
87 |
87 |
var names = connection.GetTableNames();
|
88 |
88 |
var matched = names.FirstOrDefault(param => param == PSN_HEADER_SETTING);
|
|
89 |
Dictionary<string, string> dicColCheck = new Dictionary<string, string>();
|
|
90 |
dicColCheck.Add("GROUP_ID", "TEXT");
|
|
91 |
dicColCheck.Add("DESCRIPTION", "TEXT");
|
|
92 |
dicColCheck.Add("INDEX", "INTEGER");
|
|
93 |
dicColCheck.Add("NAME", "TEXT");
|
|
94 |
|
89 |
95 |
if (matched == null)
|
90 |
96 |
{
|
91 |
97 |
var query = $"CREATE TABLE {PSN_HEADER_SETTING} (GROUP_ID TEXT, DESCRIPTION TEXT, [INDEX] INTEGER, NAME TEXT)";
|
... | ... | |
94 |
100 |
cmd.ExecuteNonQuery();
|
95 |
101 |
}
|
96 |
102 |
}
|
|
103 |
else
|
|
104 |
{
|
|
105 |
AddColumn(PSN_HEADER_SETTING, dicColCheck);
|
|
106 |
}
|
97 |
107 |
|
98 |
108 |
matched = names.FirstOrDefault(param => param == PSN_VENTDRAIN_SETTING);
|
|
109 |
dicColCheck.Clear();
|
|
110 |
dicColCheck.Add("GROUP_ID", "TEXT");
|
|
111 |
dicColCheck.Add("DESCRIPTION", "TEXT");
|
|
112 |
dicColCheck.Add("INDEX", "INTEGER");
|
|
113 |
dicColCheck.Add("NAME", "TEXT");
|
99 |
114 |
if (matched == null)
|
100 |
115 |
{
|
101 |
116 |
var query = $"CREATE TABLE {PSN_VENTDRAIN_SETTING} (GROUP_ID TEXT, DESCRIPTION TEXT, [INDEX] INTEGER, NAME TEXT)";
|
... | ... | |
104 |
119 |
cmd.ExecuteNonQuery();
|
105 |
120 |
}
|
106 |
121 |
}
|
|
122 |
else
|
|
123 |
{
|
|
124 |
AddColumn(PSN_VENTDRAIN_SETTING, dicColCheck);
|
|
125 |
}
|
107 |
126 |
|
108 |
127 |
matched = names.FirstOrDefault(param => param == PSN_TOPOLOGY_RULE);
|
|
128 |
dicColCheck.Clear();
|
|
129 |
dicColCheck.Add("UID", "TEXT");
|
109 |
130 |
if (matched == null)
|
110 |
131 |
{
|
111 |
132 |
var query = $"CREATE TABLE {PSN_TOPOLOGY_RULE} (UID TEXT)";
|
... | ... | |
125 |
146 |
|
126 |
147 |
SaveTopologyRule(topologyRule);
|
127 |
148 |
}
|
128 |
|
|
|
149 |
//else
|
|
150 |
//{
|
|
151 |
// AddColumn(PSN_TOPOLOGY_RULE, dicColCheck);
|
|
152 |
//}
|
129 |
153 |
|
130 |
154 |
matched = names.FirstOrDefault(param => param == PSN_PIPESYSTEMNETWORK);
|
|
155 |
dicColCheck.Clear();
|
|
156 |
dicColCheck.Add("OID", "NVARCHAR(255)");
|
|
157 |
dicColCheck.Add("Type", "NVARCHAR(255)");
|
|
158 |
dicColCheck.Add("OrderNumber", "NVARCHAR(255)");
|
|
159 |
dicColCheck.Add("Pipeline_OID", "NVARCHAR(255)");
|
|
160 |
dicColCheck.Add("From_Data", "NVARCHAR(255)");
|
|
161 |
dicColCheck.Add("To_Data", "NVARCHAR(255)");
|
|
162 |
dicColCheck.Add("TopologySet_OID_Key", "NVARCHAR(125)");
|
|
163 |
dicColCheck.Add("PSNRevisionNumber", "NVARCHAR(255)");
|
|
164 |
dicColCheck.Add("IsValid", "INT");
|
|
165 |
dicColCheck.Add("Status", "NVARCHAR(255)");
|
|
166 |
dicColCheck.Add("PBS", "NVARCHAR(255)");
|
|
167 |
dicColCheck.Add("Drawings", "NVARCHAR(255)");
|
|
168 |
dicColCheck.Add("IncludingVirtualData", "NVARCHAR(10)");
|
|
169 |
dicColCheck.Add("PSNAccuracy", "REAL");
|
|
170 |
|
131 |
171 |
if (matched == null)
|
132 |
172 |
{
|
133 |
173 |
var query = $"CREATE TABLE {PSN_PIPESYSTEMNETWORK} (OID NVARCHAR(255), Type NVARCHAR(255), OrderNumber NVARCHAR(255), Pipeline_OID NVARCHAR(255), From_Data NVARCHAR(255), " +
|
... | ... | |
138 |
178 |
cmd.ExecuteNonQuery();
|
139 |
179 |
}
|
140 |
180 |
}
|
|
181 |
else
|
|
182 |
{
|
|
183 |
AddColumn(PSN_PIPESYSTEMNETWORK, dicColCheck);
|
|
184 |
}
|
141 |
185 |
|
142 |
186 |
matched = names.FirstOrDefault(param => param == PSN_EQUIPMENT);
|
|
187 |
dicColCheck.Clear();
|
|
188 |
dicColCheck.Add("OID", "NVARCHAR(255)");
|
|
189 |
dicColCheck.Add("ItemTag", "NVARCHAR(255)");
|
|
190 |
dicColCheck.Add("Xcoords", "REAL");
|
|
191 |
dicColCheck.Add("Ycoords", "REAL");
|
143 |
192 |
if (matched == null)
|
144 |
193 |
{
|
145 |
194 |
var query = $"CREATE TABLE {PSN_EQUIPMENT} (OID NVARCHAR(255), ItemTag NVARCHAR(255), Xcoords REAL, Ycoords REAL)";
|
... | ... | |
148 |
197 |
cmd.ExecuteNonQuery();
|
149 |
198 |
}
|
150 |
199 |
}
|
|
200 |
else
|
|
201 |
{
|
|
202 |
AddColumn(PSN_EQUIPMENT, dicColCheck);
|
|
203 |
}
|
|
204 |
|
|
205 |
dicColCheck.Clear();
|
|
206 |
dicColCheck.Add("OID", "NVARCHAR(255)");
|
|
207 |
dicColCheck.Add("ItemTag", "NVARCHAR(255)");
|
|
208 |
dicColCheck.Add("Xcoords", "REAL");
|
|
209 |
dicColCheck.Add("Ycoords", "REAL");
|
|
210 |
dicColCheck.Add("Equipment_OID", "NVARCHAR(255)");
|
|
211 |
dicColCheck.Add("Fluid", "NVARCHAR(255)");
|
|
212 |
dicColCheck.Add("NPD", "NVARCHAR(255)");
|
|
213 |
dicColCheck.Add("PMC", "NVARCHAR(255)");
|
|
214 |
dicColCheck.Add("Rotation", "REAL");
|
|
215 |
dicColCheck.Add("FlowDirection", "NVARCHAR(255)");
|
151 |
216 |
|
152 |
217 |
matched = names.FirstOrDefault(param => param == PSN_NOZZLE);
|
153 |
218 |
if (matched == null)
|
... | ... | |
159 |
224 |
cmd.ExecuteNonQuery();
|
160 |
225 |
}
|
161 |
226 |
}
|
|
227 |
else
|
|
228 |
{
|
|
229 |
AddColumn(PSN_NOZZLE, dicColCheck);
|
|
230 |
}
|
162 |
231 |
|
163 |
232 |
matched = names.FirstOrDefault(param => param == PSN_FLUIDCODE);
|
|
233 |
dicColCheck.Clear();
|
|
234 |
dicColCheck.Add("UID", "NVARCHAR(50)");
|
|
235 |
dicColCheck.Add("Code", "NVARCHAR(255)");
|
|
236 |
dicColCheck.Add("Description", "NVARCHAR(255)");
|
|
237 |
dicColCheck.Add("Condition", "NVARCHAR(255)");
|
|
238 |
dicColCheck.Add("Remarks", "NVARCHAR(255)");
|
|
239 |
dicColCheck.Add("GroundLevel", "NVARCHAR(20)");
|
164 |
240 |
if (matched == null)
|
165 |
241 |
{
|
166 |
242 |
var query = $"CREATE TABLE {PSN_FLUIDCODE} (UID NVARCHAR(50), Code NVARCHAR(255), Description NVARCHAR(255), Condition NVARCHAR(255), Remarks NVARCHAR(255), GroundLevel NVARCHAR(20))";
|
... | ... | |
169 |
245 |
cmd.ExecuteNonQuery();
|
170 |
246 |
}
|
171 |
247 |
}
|
172 |
|
|
|
248 |
else
|
|
249 |
{
|
|
250 |
AddColumn(PSN_FLUIDCODE, dicColCheck);
|
|
251 |
}
|
173 |
252 |
|
174 |
253 |
matched = names.FirstOrDefault(param => param == PSN_PIPINGMATLCLASS);
|
|
254 |
dicColCheck.Clear();
|
|
255 |
dicColCheck.Add("UID", "NVARCHAR(50)");
|
|
256 |
dicColCheck.Add("Priority", "INTEGER");
|
|
257 |
dicColCheck.Add("Code", "NVARCHAR(255)");
|
|
258 |
dicColCheck.Add("Description", "NVARCHAR(255)");
|
|
259 |
dicColCheck.Add("Condition", "NVARCHAR(255)");
|
|
260 |
dicColCheck.Add("Remarks", "NVARCHAR(255)");
|
|
261 |
dicColCheck.Add("GroundLevel", "NVARCHAR(20)");
|
175 |
262 |
if (matched == null)
|
176 |
263 |
{
|
177 |
264 |
var query = $"CREATE TABLE {PSN_PIPINGMATLCLASS} (UID NVARCHAR(50), Priority INTEGER, Code NVARCHAR(255), Description NVARCHAR(255), Condition NVARCHAR(255), Remarks NVARCHAR(255), GroundLevel NVARCHAR(20))";
|
... | ... | |
180 |
267 |
cmd.ExecuteNonQuery();
|
181 |
268 |
}
|
182 |
269 |
}
|
|
270 |
else
|
|
271 |
{
|
|
272 |
AddColumn(PSN_PIPINGMATLCLASS, dicColCheck);
|
|
273 |
}
|
183 |
274 |
|
184 |
275 |
matched = names.FirstOrDefault(param => param == PSN_SEQUENCEDATA);
|
|
276 |
dicColCheck.Clear();
|
|
277 |
dicColCheck.Add("OID", "NVARCHAR(255)");
|
|
278 |
dicColCheck.Add("SERIALNUMBER", "NVARCHAR(255)");
|
|
279 |
dicColCheck.Add("PathItem_OID", "NVARCHAR(255)");
|
|
280 |
dicColCheck.Add("TopologySet_OID_Key", "NVARCHAR(255)");
|
185 |
281 |
if (matched == null)
|
186 |
282 |
{
|
187 |
283 |
var query = $"CREATE TABLE {PSN_SEQUENCEDATA} (OID NVARCHAR(255), SERIALNUMBER NVARCHAR(255), PathItem_OID NVARCHAR(255), TopologySet_OID_Key NVARCHAR(255))";
|
... | ... | |
190 |
286 |
cmd.ExecuteNonQuery();
|
191 |
287 |
}
|
192 |
288 |
}
|
|
289 |
else
|
|
290 |
{
|
|
291 |
AddColumn(PSN_SEQUENCEDATA, dicColCheck);
|
|
292 |
}
|
193 |
293 |
|
194 |
294 |
matched = names.FirstOrDefault(param => param == PSN_PATHITEMS);
|
|
295 |
dicColCheck.Clear();
|
|
296 |
dicColCheck.Add("OID", "NVARCHAR(255)");
|
|
297 |
dicColCheck.Add("SequenceData_OID", "NVARCHAR(255)");
|
|
298 |
dicColCheck.Add("TopologySet_OID", "NVARCHAR(255)");
|
|
299 |
dicColCheck.Add("BranchTopologySet_OID", "NVARCHAR(255)");
|
|
300 |
dicColCheck.Add("PipeLine_OID", "NVARCHAR(255)");
|
|
301 |
dicColCheck.Add("ItemName", "NVARCHAR(255)");
|
|
302 |
dicColCheck.Add("ItemTag", "NVARCHAR(255)");
|
|
303 |
dicColCheck.Add("DESCRIPTION", "NVARCHAR(255)");
|
|
304 |
dicColCheck.Add("CLASS", "NVARCHAR(255)");
|
|
305 |
dicColCheck.Add("SUBCLASS", "NVARCHAR(255)");
|
|
306 |
dicColCheck.Add("TYPE", "NVARCHAR(255)");
|
|
307 |
dicColCheck.Add("PIDNAME", "NVARCHAR(255)");
|
|
308 |
dicColCheck.Add("Equipment_OID", "NVARCHAR(255)");
|
|
309 |
dicColCheck.Add("NPD", "NVARCHAR(255)");
|
|
310 |
dicColCheck.Add("PipeSystemNetwork_OID", "NVARCHAR(255)");
|
|
311 |
dicColCheck.Add("PipeRun_OID", "NVARCHAR(255)");
|
|
312 |
dicColCheck.Add("ViewPipeSystemNetwork_OID", "NVARCHAR(255)");
|
195 |
313 |
if (matched == null)
|
196 |
314 |
{
|
197 |
315 |
var query = $"CREATE TABLE {PSN_PATHITEMS} (OID NVARCHAR(255), SequenceData_OID NVARCHAR(255), " +
|
... | ... | |
203 |
321 |
cmd.ExecuteNonQuery();
|
204 |
322 |
}
|
205 |
323 |
}
|
206 |
|
|
|
324 |
else
|
|
325 |
{
|
|
326 |
AddColumn(PSN_PATHITEMS, dicColCheck);
|
|
327 |
}
|
|
328 |
|
207 |
329 |
matched = names.FirstOrDefault(param => param == PSN_VIEW);
|
|
330 |
dicColCheck.Clear();
|
|
331 |
dicColCheck.Add("OID", "TEXT");
|
208 |
332 |
if (matched == null)
|
209 |
333 |
{
|
210 |
334 |
var query = $"CREATE TABLE {PSN_VIEW} (OID TEXT)";
|
... | ... | |
215 |
339 |
}
|
216 |
340 |
|
217 |
341 |
matched = names.FirstOrDefault(param => param == PSN_TOPOLOGYSET);
|
|
342 |
dicColCheck.Clear();
|
|
343 |
dicColCheck.Add("OID", "NVARCHAR(255)");
|
|
344 |
dicColCheck.Add("Type", "NVARCHAR(255)");
|
|
345 |
dicColCheck.Add("SubType", "NVARCHAR(255)");
|
|
346 |
dicColCheck.Add("HeadItemTag", "NVARCHAR(255)");
|
|
347 |
dicColCheck.Add("TailItemTag", "NVARCHAR(255)");
|
|
348 |
dicColCheck.Add("HeadItemSPID", "NVARCHAR(255)");
|
|
349 |
dicColCheck.Add("TailItemSPID", "NVARCHAR(255)");
|
|
350 |
|
218 |
351 |
if (matched == null)
|
219 |
352 |
{
|
220 |
353 |
var query = $"CREATE TABLE { PSN_TOPOLOGYSET} (OID NVARCHAR(255), Type NVARCHAR(255), SubType NVARCHAR(255), HeadItemTag NVARCHAR(255), TailItemTag NVARCHAR(255), HeadItemSPID NVARCHAR(255), TailItemSPID NVARCHAR(255))";
|
... | ... | |
223 |
356 |
cmd.ExecuteNonQuery();
|
224 |
357 |
}
|
225 |
358 |
}
|
226 |
|
|
|
359 |
else
|
|
360 |
{
|
|
361 |
AddColumn(PSN_TOPOLOGYSET, dicColCheck);
|
|
362 |
}
|
|
363 |
|
227 |
364 |
matched = names.FirstOrDefault(param => param == PSN_TRANSFORMKEYWORD_SETTING);
|
|
365 |
dicColCheck.Clear();
|
|
366 |
dicColCheck.Add("[INDEX]", "INTEGER");
|
|
367 |
dicColCheck.Add("[NAME]", "TEXT");
|
|
368 |
dicColCheck.Add("[KEYWORD]", "TEXT");
|
228 |
369 |
if (matched == null)
|
229 |
370 |
{
|
230 |
371 |
var query = $"CREATE TABLE {PSN_TRANSFORMKEYWORD_SETTING} ([INDEX] INTEGER, [NAME] TEXT, [KEYWORD] TEXT)";
|
... | ... | |
233 |
374 |
cmd.ExecuteNonQuery();
|
234 |
375 |
}
|
235 |
376 |
}
|
|
377 |
else
|
|
378 |
{
|
|
379 |
AddColumn(PSN_TRANSFORMKEYWORD_SETTING, dicColCheck);
|
|
380 |
}
|
236 |
381 |
|
237 |
382 |
matched = names.FirstOrDefault(param => param == PSN_PIPELINE);
|
|
383 |
dicColCheck.Clear();
|
|
384 |
dicColCheck.Add("OID", "NVARCHAR(255)");
|
|
385 |
dicColCheck.Add("PipeSystem_OID", "NVARCHAR(255)");
|
|
386 |
dicColCheck.Add("FLUID", "NVARCHAR(255)");
|
|
387 |
dicColCheck.Add("PMC", "NVARCHAR(255)");
|
|
388 |
dicColCheck.Add("SEQNUMBER", "NVARCHAR(255)");
|
|
389 |
dicColCheck.Add("INSULATION", "NVARCHAR(255)");
|
|
390 |
dicColCheck.Add("FROM_DATA", "NVARCHAR(255)");
|
|
391 |
dicColCheck.Add("TO_DATA", "NVARCHAR(255)");
|
|
392 |
dicColCheck.Add("Unit", "NVARCHAR(100)");
|
238 |
393 |
if (matched == null)
|
239 |
394 |
{
|
240 |
395 |
var query = $"CREATE TABLE {PSN_PIPELINE} (OID NVARCHAR(255), PipeSystem_OID NVARCHAR(255), FLUID NVARCHAR(255), PMC NVARCHAR(255), SEQNUMBER NVARCHAR(255), INSULATION NVARCHAR(255), " +
|
... | ... | |
244 |
399 |
cmd.ExecuteNonQuery();
|
245 |
400 |
}
|
246 |
401 |
}
|
|
402 |
else
|
|
403 |
{
|
|
404 |
AddColumn(PSN_PIPELINE, dicColCheck);
|
|
405 |
}
|
247 |
406 |
|
248 |
407 |
matched = names.FirstOrDefault(param => param == PSN_INSULATIONPURPOSE);
|
|
408 |
dicColCheck.Clear();
|
|
409 |
dicColCheck.Add("UID", "NVARCHAR(50)");
|
|
410 |
dicColCheck.Add("Code", "NVARCHAR(255)");
|
|
411 |
dicColCheck.Add("Description", "NVARCHAR(255)");
|
|
412 |
dicColCheck.Add("Remarks", "NVARCHAR(255)");
|
249 |
413 |
if (matched == null)
|
250 |
414 |
{
|
251 |
415 |
var query = $"CREATE TABLE {PSN_INSULATIONPURPOSE} (UID NVARCHAR(50), Code NVARCHAR(255), Description NVARCHAR(255), Remarks NVARCHAR(255))";
|
... | ... | |
254 |
418 |
cmd.ExecuteNonQuery();
|
255 |
419 |
}
|
256 |
420 |
}
|
|
421 |
else
|
|
422 |
{
|
|
423 |
AddColumn(PSN_INSULATIONPURPOSE, dicColCheck);
|
|
424 |
}
|
|
425 |
|
|
426 |
void AddColumn(string TableName, Dictionary<string, string> dicCol)
|
|
427 |
{
|
|
428 |
var colnames = connection.GetColumnNames(TableName);
|
|
429 |
bool check = false;
|
|
430 |
if (colnames != null)
|
|
431 |
{
|
|
432 |
foreach (KeyValuePair<string, string> col in dicCol)
|
|
433 |
{
|
|
434 |
check = false;
|
|
435 |
foreach (string c in colnames)
|
|
436 |
{
|
|
437 |
if (col.Key.Contains(c))
|
|
438 |
{
|
|
439 |
check = true;
|
|
440 |
break;
|
|
441 |
}
|
|
442 |
}
|
|
443 |
|
|
444 |
if (!check) //없으면 추가
|
|
445 |
{
|
|
446 |
string i = string.Empty;
|
|
447 |
if (col.Value.ToString().ToUpper().Contains("INT") || col.Value.ToString().ToUpper().Contains("REAL"))
|
|
448 |
i = "DEFAULT 0";
|
|
449 |
|
|
450 |
var query = $"ALTER TABLE " + TableName + " ADD [" + col.Key + "] " + col.Value + " " + i + ";";
|
|
451 |
using (var cmd = connection.GetSqlStringCommand(query))
|
|
452 |
{
|
|
453 |
cmd.ExecuteNonQuery();
|
|
454 |
}
|
|
455 |
}
|
|
456 |
}
|
|
457 |
}
|
|
458 |
}
|
257 |
459 |
|
258 |
460 |
result = true;
|
259 |
461 |
}
|
... | ... | |
400 |
602 |
DataTable dt = null;
|
401 |
603 |
ID2Info id2Info = ID2Info.GetInstance();
|
402 |
604 |
|
403 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
605 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
404 |
606 |
{
|
405 |
607 |
try
|
406 |
608 |
{
|
... | ... | |
448 |
650 |
DataTable dt = null;
|
449 |
651 |
ID2Info id2Info = ID2Info.GetInstance();
|
450 |
652 |
|
451 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
653 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
452 |
654 |
{
|
453 |
655 |
try
|
454 |
656 |
{
|
... | ... | |
636 |
838 |
|
637 |
839 |
foreach (string value in values)
|
638 |
840 |
{
|
639 |
|
query = $"INSERT INTO {PSN_VIEW} VALUES (@OID)";
|
|
841 |
query = $"INSERT INTO {PSN_VIEW} (OID) VALUES (@OID)";
|
640 |
842 |
var cmd = connection.GetSqlStringCommand(query);
|
641 |
843 |
AddWithValue(cmd, "@OID", value);
|
642 |
844 |
connection.ExecuteNonQuery(cmd, txn);
|
... | ... | |
700 |
902 |
DataTable dt = null;
|
701 |
903 |
ID2Info id2Info = ID2Info.GetInstance();
|
702 |
904 |
|
703 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
905 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
704 |
906 |
{
|
705 |
907 |
try
|
706 |
908 |
{
|
... | ... | |
724 |
926 |
DataTable dt = null;
|
725 |
927 |
ID2Info id2Info = ID2Info.GetInstance();
|
726 |
928 |
|
727 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
929 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
728 |
930 |
{
|
729 |
931 |
try
|
730 |
932 |
{
|
... | ... | |
748 |
950 |
DataTable dt = null;
|
749 |
951 |
ID2Info id2Info = ID2Info.GetInstance();
|
750 |
952 |
|
751 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
953 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
752 |
954 |
{
|
753 |
955 |
try
|
754 |
956 |
{
|
... | ... | |
770 |
972 |
public static bool SaveHeaderSetting(List<HeaderInfo> headerInfos)
|
771 |
973 |
{
|
772 |
974 |
ID2Info id2Info = ID2Info.GetInstance();
|
773 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
975 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
774 |
976 |
{
|
775 |
977 |
try
|
776 |
978 |
{
|
... | ... | |
783 |
985 |
{
|
784 |
986 |
foreach (HeaderItem item in headerInfo.HeaderItems)
|
785 |
987 |
{
|
786 |
|
query = $"INSERT INTO {PSN_HEADER_SETTING} VALUES (@GROUP_ID, @DESCRIPTION, @INDEX, @NAME)";
|
|
988 |
query = $"INSERT INTO {PSN_HEADER_SETTING} (GROUP_ID, DESCRIPTION, [INDEX], NAME) VALUES (@GROUP_ID, @DESCRIPTION, @INDEX, @NAME)";
|
787 |
989 |
var cmd = connection.GetSqlStringCommand(query);
|
788 |
990 |
AddWithValue(cmd, "@GROUP_ID", headerInfo.UID);
|
789 |
991 |
AddWithValue(cmd, "@DESCRIPTION", headerInfo.Description);
|
... | ... | |
808 |
1010 |
public static bool SaveVentDrainSetting(List<VentDrainInfo> ventDrainInfos)
|
809 |
1011 |
{
|
810 |
1012 |
ID2Info id2Info = ID2Info.GetInstance();
|
811 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1013 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
812 |
1014 |
{
|
813 |
1015 |
using (var txn = connection.BeginTransaction())
|
814 |
1016 |
{
|
... | ... | |
821 |
1023 |
{
|
822 |
1024 |
foreach (VentDrainItem item in ventDrainInfo.VentDrainItems)
|
823 |
1025 |
{
|
824 |
|
query = $"INSERT INTO {PSN_VENTDRAIN_SETTING} VALUES (@GROUP_ID, @DESCRIPTION, @INDEX, @NAME)";
|
|
1026 |
query = $"INSERT INTO {PSN_VENTDRAIN_SETTING} (GROUP_ID, DESCRIPTION, [INDEX], NAME) VALUES (@GROUP_ID, @DESCRIPTION, @INDEX, @NAME)";
|
825 |
1027 |
var cmd = connection.GetSqlStringCommand(query);
|
826 |
1028 |
AddWithValue(cmd, "@GROUP_ID", ventDrainInfo.UID);
|
827 |
1029 |
AddWithValue(cmd, "@DESCRIPTION", ventDrainInfo.Description);
|
... | ... | |
847 |
1049 |
public static bool SaveKeywordsSetting(List<KeywordItem> keywordItems)
|
848 |
1050 |
{
|
849 |
1051 |
ID2Info id2Info = ID2Info.GetInstance();
|
850 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1052 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
851 |
1053 |
{
|
852 |
1054 |
using (var txn = connection.BeginTransaction())
|
853 |
1055 |
{
|
... | ... | |
858 |
1060 |
|
859 |
1061 |
foreach (KeywordItem item in keywordItems)
|
860 |
1062 |
{
|
861 |
|
query = $"INSERT INTO {PSN_TRANSFORMKEYWORD_SETTING} VALUES (@INDEX, @NAME, @KEYWORD)";
|
|
1063 |
query = $"INSERT INTO {PSN_TRANSFORMKEYWORD_SETTING} ([INDEX], NAME, KEYWORD) VALUES (@INDEX, @NAME, @KEYWORD)";
|
862 |
1064 |
var cmd = connection.GetSqlStringCommand(query);
|
863 |
1065 |
AddWithValue(cmd, "@INDEX", item.Index);
|
864 |
1066 |
AddWithValue(cmd, "@NAME", item.Name);
|
... | ... | |
882 |
1084 |
public static bool SaveTopologyRule(DataTable dt)
|
883 |
1085 |
{
|
884 |
1086 |
ID2Info id2Info = ID2Info.GetInstance();
|
885 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1087 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
886 |
1088 |
{
|
887 |
1089 |
using (var txn = connection.BeginTransaction())
|
888 |
1090 |
{
|
... | ... | |
890 |
1092 |
{
|
891 |
1093 |
var query = $"DELETE FROM {PSN_TOPOLOGY_RULE}";
|
892 |
1094 |
var cmd = connection.GetSqlStringCommand(query);
|
893 |
|
cmd.ExecuteNonQuery();
|
|
1095 |
//connection.ExecuteNonQuery(connection.GetSqlStringCommand(query), txn);
|
|
1096 |
connection.ExecuteNonQuery(cmd, txn);
|
894 |
1097 |
|
895 |
1098 |
foreach (DataRow row in dt.Rows)
|
896 |
1099 |
{
|
897 |
|
query = $"INSERT INTO {PSN_TOPOLOGY_RULE} VALUES (@UID)";
|
|
1100 |
query = $"INSERT INTO {PSN_TOPOLOGY_RULE} (UID) VALUES (@UID)";
|
898 |
1101 |
cmd = connection.GetSqlStringCommand(query);
|
899 |
1102 |
AddWithValue(cmd, "@UID", row["NAME"].ToString());
|
900 |
1103 |
connection.ExecuteNonQuery(cmd, txn);
|
... | ... | |
919 |
1122 |
DataTable dt = null;
|
920 |
1123 |
|
921 |
1124 |
ID2Info id2Info = ID2Info.GetInstance();
|
922 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1125 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
923 |
1126 |
{
|
924 |
1127 |
try
|
925 |
1128 |
{
|
... | ... | |
951 |
1154 |
ID2Info id2Info = ID2Info.GetInstance();
|
952 |
1155 |
|
953 |
1156 |
bool result = true;
|
954 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1157 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
955 |
1158 |
{
|
956 |
1159 |
try
|
957 |
1160 |
{
|
... | ... | |
965 |
1168 |
for (int i = 0; i < item.PathItems.Rows.Count; i++)
|
966 |
1169 |
{
|
967 |
1170 |
DataRow row = item.PathItems.Rows[i];
|
968 |
|
query = $"INSERT INTO {PSN_PATHITEMS} VALUES (@OID, @SequenceData_OID, @TopologySet_OID, @BranchTopologySet_OID, @PipeLine_OID, @ITEMNAME, @ITEMTAG, @DESCRIPTION, @Class, @SubClass, @TYPE, @PIDNAME, @Equipment_OID, @NPD, @PipeSystemNetwork_OID,@PipeRun_OID, @ViewPipeSystemNetwork_OID)";
|
|
1171 |
query = $"INSERT INTO {PSN_PATHITEMS} " +
|
|
1172 |
$"(OID, SequenceData_OID, TopologySet_OID, BranchTopologySet_OID, PipeLine_OID, ItemName, ItemTag, DESCRIPTION, CLASS, SUBCLASS, TYPE, " +
|
|
1173 |
$"PIDNAME, Equipment_OID, NPD, PipeSystemNetwork_OID, PipeRun_OID, ViewPipeSystemNetwork_OID) VALUES " +
|
|
1174 |
$"(@OID, @SequenceData_OID, @TopologySet_OID, @BranchTopologySet_OID, @PipeLine_OID, @ITEMNAME, @ITEMTAG, @DESCRIPTION, @Class, @SubClass, @TYPE, @PIDNAME, @Equipment_OID, @NPD, @PipeSystemNetwork_OID,@PipeRun_OID, @ViewPipeSystemNetwork_OID)";
|
969 |
1175 |
var cmd = connection.GetSqlStringCommand(query);
|
970 |
1176 |
AddWithValue(cmd, "@OID", string.IsNullOrEmpty(row["OID"].ToString()) ? "" : row["OID"].ToString());
|
971 |
1177 |
AddWithValue(cmd, "@SequenceData_OID", string.IsNullOrEmpty(row["SequenceData_OID"].ToString()) ? "" : row["SequenceData_OID"].ToString());
|
... | ... | |
992 |
1198 |
connection.ExecuteNonQuery(connection.GetSqlStringCommand(query), txn);
|
993 |
1199 |
foreach (DataRow row in item.SequenceData.Rows)
|
994 |
1200 |
{
|
995 |
|
query = $"INSERT INTO {PSN_SEQUENCEDATA} VALUES (@OID, @SERIALNUMBER, @PathItem_OID, @TopologySet_OID_Key)";
|
|
1201 |
query = $"INSERT INTO {PSN_SEQUENCEDATA} (OID, SERIALNUMBER, PathItem_OID, TopologySet_OID_Key) VALUES (@OID, @SERIALNUMBER, @PathItem_OID, @TopologySet_OID_Key)";
|
996 |
1202 |
var cmd = connection.GetSqlStringCommand(query);
|
997 |
1203 |
AddWithValue(cmd, "@OID", string.IsNullOrEmpty(row["OID"].ToString()) ? "" : row["OID"].ToString());
|
998 |
1204 |
AddWithValue(cmd, "@SERIALNUMBER", string.IsNullOrEmpty(row["SERIALNUMBER"].ToString()) ? "" : row["SERIALNUMBER"].ToString());
|
... | ... | |
1006 |
1212 |
connection.ExecuteNonQuery(connection.GetSqlStringCommand(query), txn);
|
1007 |
1213 |
foreach (DataRow row in item.Nozzle.Rows)
|
1008 |
1214 |
{
|
1009 |
|
query = $"INSERT INTO {PSN_NOZZLE} VALUES (@OID, @ITEMTAG, @XCOORDS, @YCOORDS, @Equipment_OID, @FLUID, @NPD, @PMC, @ROTATION, @FlowDirection)";
|
|
1215 |
query = $"INSERT INTO {PSN_NOZZLE} (OID, ItemTag, Xcoords, Ycoords, Equipment_OID, Fluid, NPD, PMC, Rotation, FlowDirection) VALUES (@OID, @ITEMTAG, @XCOORDS, @YCOORDS, @Equipment_OID, @FLUID, @NPD, @PMC, @ROTATION, @FlowDirection)";
|
1010 |
1216 |
var cmd = connection.GetSqlStringCommand(query);
|
1011 |
1217 |
AddWithValue(cmd, "@OID", string.IsNullOrEmpty(row["OID"].ToString()) ? "" : row["OID"].ToString());
|
1012 |
1218 |
AddWithValue(cmd, "@ITEMTAG", string.IsNullOrEmpty(row["ITEMTAG"].ToString()) ? "" : row["ITEMTAG"].ToString());
|
... | ... | |
1040 |
1246 |
connection.ExecuteNonQuery(connection.GetSqlStringCommand(query), txn);
|
1041 |
1247 |
foreach (DataRow row in item.Equipment.Rows)
|
1042 |
1248 |
{
|
1043 |
|
query = $"INSERT INTO {PSN_EQUIPMENT} VALUES (@OID, @ITEMTAG, @XCOORDS, @YCOORDS)";
|
|
1249 |
query = $"INSERT INTO {PSN_EQUIPMENT} (OID, ItemTag, Xcoords, Ycoords) VALUES (@OID, @ITEMTAG, @XCOORDS, @YCOORDS)";
|
1044 |
1250 |
var cmd = connection.GetSqlStringCommand(query);
|
1045 |
1251 |
AddWithValue(cmd, "@OID", string.IsNullOrEmpty(row["OID"].ToString()) ? "" : row["OID"].ToString());
|
1046 |
1252 |
AddWithValue(cmd, "@ITEMTAG", string.IsNullOrEmpty(row["ITEMTAG"].ToString()) ? "" : row["ITEMTAG"].ToString());
|
... | ... | |
1063 |
1269 |
connection.ExecuteNonQuery(connection.GetSqlStringCommand(query), txn);
|
1064 |
1270 |
foreach (DataRow row in item.TopologySet.Rows)
|
1065 |
1271 |
{
|
1066 |
|
query = $"INSERT INTO {PSN_TOPOLOGYSET} VALUES (@OID, @Type, @SubType, @HeadItemTag, @TailItemTag, @HeadItemSPID, @TailItemSPID)";
|
|
1272 |
query = $"INSERT INTO {PSN_TOPOLOGYSET} (OID, Type, SubType, HeadItemTag, TailItemTag, HeadItemSPID, TailItemSPID) VALUES (@OID, @Type, @SubType, @HeadItemTag, @TailItemTag, @HeadItemSPID, @TailItemSPID)";
|
1067 |
1273 |
var cmd = connection.GetSqlStringCommand(query);
|
1068 |
1274 |
AddWithValue(cmd, "@OID", string.IsNullOrEmpty(row["OID"].ToString()) ? "" : row["OID"].ToString());
|
1069 |
1275 |
AddWithValue(cmd, "@Type", string.IsNullOrEmpty(row["Type"].ToString()) ? "" : row["Type"].ToString());
|
... | ... | |
1121 |
1327 |
connection.ExecuteNonQuery(connection.GetSqlStringCommand(query), txn);
|
1122 |
1328 |
foreach (DataRow row in item.PipeLine.Rows)
|
1123 |
1329 |
{
|
1124 |
|
query = $"INSERT INTO {PSN_PIPELINE} VALUES (@OID, @PipeSystem_OID, @FLUID, @PMC, @SEQNUMBER, @INSULATION, @FROM_DATA, @TO_DATA, @Unit)";
|
|
1330 |
query = $"INSERT INTO {PSN_PIPELINE} (OID, PipeSystem_OID, FLUID, PMC, SEQNUMBER, INSULATION, FROM_DATA, TO_DATA, Unit) VALUES (@OID, @PipeSystem_OID, @FLUID, @PMC, @SEQNUMBER, @INSULATION, @FROM_DATA, @TO_DATA, @Unit)";
|
1125 |
1331 |
var cmd = connection.GetSqlStringCommand(query);
|
1126 |
1332 |
AddWithValue(cmd, "@OID", row["OID"].ToString());
|
1127 |
1333 |
AddWithValue(cmd, "@PipeSystem_OID", row["PipeSystem_OID"].ToString());
|
... | ... | |
1159 |
1365 |
ID2Info id2Info = ID2Info.GetInstance();
|
1160 |
1366 |
|
1161 |
1367 |
bool result = true;
|
1162 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1368 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
1163 |
1369 |
{
|
1164 |
1370 |
try
|
1165 |
1371 |
{
|
... | ... | |
1172 |
1378 |
|
1173 |
1379 |
foreach (DataRow row in dt.Rows)
|
1174 |
1380 |
{
|
1175 |
|
query = $"INSERT INTO {PSN_FLUIDCODE} VALUES (@UID, @Code, @Description, @Condition, @Remarks, @GroundLevel)";
|
|
1381 |
query = $"INSERT INTO {PSN_FLUIDCODE} (UID, Code, Description, Condition, Remarks, GroundLevel) VALUES (@UID, @Code, @Description, @Condition, @Remarks, @GroundLevel)";
|
1176 |
1382 |
var cmd = connection.GetSqlStringCommand(query);
|
1177 |
1383 |
cmd.Parameters.Clear();
|
1178 |
1384 |
|
... | ... | |
1244 |
1450 |
DataTable dt = null;
|
1245 |
1451 |
ID2Info id2Info = ID2Info.GetInstance();
|
1246 |
1452 |
|
1247 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1453 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
1248 |
1454 |
{
|
1249 |
1455 |
try
|
1250 |
1456 |
{
|
... | ... | |
1268 |
1474 |
ID2Info id2Info = ID2Info.GetInstance();
|
1269 |
1475 |
|
1270 |
1476 |
bool result = true;
|
1271 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1477 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
1272 |
1478 |
{
|
1273 |
1479 |
try
|
1274 |
1480 |
{
|
... | ... | |
1281 |
1487 |
|
1282 |
1488 |
foreach (DataRow row in dt.Rows)
|
1283 |
1489 |
{
|
1284 |
|
query = $"INSERT INTO {PSN_PIPINGMATLCLASS} VALUES (@UID, @Priority, @Code, @Description, @Condition, @Remarks, @GroundLevel)";
|
|
1490 |
query = $"INSERT INTO {PSN_PIPINGMATLCLASS} ( UID, Priority, Code, Description, Condition, Remarks, GroundLevel) VALUES (@UID, @Priority, @Code, @Description, @Condition, @Remarks, @GroundLevel)";
|
1285 |
1491 |
var cmd = connection.GetSqlStringCommand(query);
|
1286 |
1492 |
cmd.Parameters.Clear();
|
1287 |
1493 |
|
... | ... | |
1361 |
1567 |
ID2Info id2Info = ID2Info.GetInstance();
|
1362 |
1568 |
|
1363 |
1569 |
bool result = true;
|
1364 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1570 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
1365 |
1571 |
{
|
1366 |
1572 |
try
|
1367 |
1573 |
{
|
... | ... | |
1374 |
1580 |
|
1375 |
1581 |
foreach (DataRow row in dt.Rows)
|
1376 |
1582 |
{
|
1377 |
|
query = $"INSERT INTO {PSN_INSULATIONPURPOSE} VALUES (@UID, @Code, @Description, @Remarks)";
|
|
1583 |
query = $"INSERT INTO {PSN_INSULATIONPURPOSE} (UID, Code, Description, Remarks) VALUES (@UID, @Code, @Description, @Remarks)";
|
1378 |
1584 |
var cmd = connection.GetSqlStringCommand(query);
|
1379 |
1585 |
cmd.Parameters.Clear();
|
1380 |
1586 |
|
... | ... | |
1433 |
1639 |
PSN result = new PSN();
|
1434 |
1640 |
ID2Info id2Info = ID2Info.GetInstance();
|
1435 |
1641 |
|
1436 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1642 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
1437 |
1643 |
{
|
1438 |
1644 |
try
|
1439 |
1645 |
{
|
... | ... | |
1538 |
1744 |
int result = 0;
|
1539 |
1745 |
ID2Info id2Info = ID2Info.GetInstance();
|
1540 |
1746 |
|
1541 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1747 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
1542 |
1748 |
{
|
1543 |
1749 |
try
|
1544 |
1750 |
{
|
... | ... | |
1571 |
1777 |
DataTable dt = null;
|
1572 |
1778 |
|
1573 |
1779 |
ID2Info id2Info = ID2Info.GetInstance();
|
1574 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1780 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
1575 |
1781 |
{
|
1576 |
1782 |
try
|
1577 |
1783 |
{
|
... | ... | |
1595 |
1801 |
DataTable dt = null;
|
1596 |
1802 |
|
1597 |
1803 |
ID2Info id2Info = ID2Info.GetInstance();
|
1598 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1804 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
1599 |
1805 |
{
|
1600 |
1806 |
try
|
1601 |
1807 |
{
|
... | ... | |
1631 |
1837 |
DataTable dt = null;
|
1632 |
1838 |
|
1633 |
1839 |
ID2Info id2Info = ID2Info.GetInstance();
|
1634 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1840 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
1635 |
1841 |
{
|
1636 |
1842 |
try
|
1637 |
1843 |
{
|
... | ... | |
1688 |
1894 |
DataTable dt = null;
|
1689 |
1895 |
|
1690 |
1896 |
ID2Info id2Info = ID2Info.GetInstance();
|
1691 |
|
using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
|
|
1897 |
using (IAbstractDatabase connection = id2Info.CreateConnection())
|
1692 |
1898 |
{
|
1693 |
1899 |
try
|
1694 |
1900 |
{
|