187 |
MySqlCommand updateCmd = new MySqlCommand(updateSql, sqlWriteConnection); |
MySqlCommand updateCmd = new MySqlCommand(updateSql, sqlWriteConnection); |
188 |
int numrows = updateCmd.ExecuteNonQuery(); |
int numrows = updateCmd.ExecuteNonQuery(); |
189 |
|
|
190 |
translog.WriteLine(getNowString() + " " + msgString + "\n"); |
translog.WriteLine(getNowString() + " " + msgString); |
191 |
|
|
192 |
if (numrows != 1) |
if (numrows != 1) |
193 |
{ |
{ |
285 |
|
|
286 |
if (numrows == 1) |
if (numrows == 1) |
287 |
{ |
{ |
288 |
translog.WriteLine(getNowString() + " " + msgString + "\n"); |
translog.WriteLine(getNowString() + " " + msgString); |
289 |
mqMgr.Commit(); |
mqMgr.Commit(); |
290 |
statusData.counter++; |
statusData.counter++; |
291 |
} |
} |