pt/dotnet_runner
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fix transaction calls

Browse Source
This commit is contained in:
Paul Trowbridge 2018-08-16 12:23:18 -04:00
parent 855add36cf
commit 19ab7d7231
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
runner.cs
View File

@ -52,7 +52,7 @@ namespace test
Console.Write("etl start:" + DateTime.Now.ToString()); Console.Write("etl start:" + DateTime.Now.ToString());
Console.Write(Environment.NewLine); Console.Write(Environment.NewLine);
pgc.BeginTransaction(); NpgsqlTransaction pgt = pgc.BeginTransaction();
//--------------------------------------------move to target-------------------------------------------------------- //--------------------------------------------move to target--------------------------------------------------------
var ibmdr = ibmcmd.ExecuteReader(); var ibmdr = ibmcmd.ExecuteReader();
@ -140,11 +140,14 @@ namespace test
Console.Write(Environment.NewLine); Console.Write(Environment.NewLine);
Console.Write(e.Message); Console.Write(e.Message);
ibmc.Close(); ibmc.Close();
pgt.Rollback();
pgc.Close(); pgc.Close();
} }
sql = ""; sql = "";
} }
pgt.Commit();
ibmc.Close(); ibmc.Close();
pgc.Close(); pgc.Close();