/[projects]/dao/DaoMqPump2/DaoMqPump2/Transport.cs
ViewVC logotype

Diff of /dao/DaoMqPump2/DaoMqPump2/Transport.cs

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 2057 by torben, Tue Aug 27 06:49:36 2013 UTC revision 2058 by torben, Wed Aug 28 06:45:20 2013 UTC
# Line 16  namespace DaoMqPump2 Line 16  namespace DaoMqPump2
16    
17          enum LogfileType {          enum LogfileType {
18              LogTransactions,              LogTransactions,
19              LogEvents              LogEvents,
20                LogDiscarded
21          }          }
22    
23          public static string SQL2MQ = "sql2mq";          public static string SQL2MQ = "sql2mq";
# Line 279  namespace DaoMqPump2 Line 280  namespace DaoMqPump2
280                                      string msgString = mqMsg.ReadString(mqMsg.MessageLength);                                      string msgString = mqMsg.ReadString(mqMsg.MessageLength);
281                                      System.Console.WriteLine(msgString);                                      System.Console.WriteLine(msgString);
282    
283                                        if ( msgString.StartsWith("?") ) //Hvis transaktionen starter med et ? er det ikke en gyldig transaktion
284                                        {
285                                            string discarded_filename = getLogFilename(LogfileType.LogDiscarded);
286                                            using (StreamWriter discardedlog = new StreamWriter(discarded_filename, true))
287                                            {
288                                                discardedlog.WriteLine(msgString);
289                                            }
290                                            mqMgr.Commit();//fjern den afviste transaktion fra køen
291                                            statusData.discardedCounter++;
292                                            continue; //gå frem til at tage næste transaktion fra køen
293                                        }
294    
295    
296                                      string sql = "CALL " + mq2sqlInsertQuery + "( '" + MySqlHelper.EscapeString(msgString) + "' )"; //opbygger en CALL somestoredprocedure('msgString'); sql streng                                      string sql = "CALL " + mq2sqlInsertQuery + "( '" + MySqlHelper.EscapeString(msgString) + "' )"; //opbygger en CALL somestoredprocedure('msgString'); sql streng
297    
298                                      MySqlCommand sqlcmd = new MySqlCommand(sql, sqlConnection);                                      MySqlCommand sqlcmd = new MySqlCommand(sql, sqlConnection);
# Line 422  namespace DaoMqPump2 Line 436  namespace DaoMqPump2
436                  case LogfileType.LogTransactions:                  case LogfileType.LogTransactions:
437                      filename += "transactionlog_";                      filename += "transactionlog_";
438                      break;                      break;
439                    case LogfileType.LogDiscarded:
440                        filename += "discardedlog_";
441                        break;
442              }              }
443    
444    
Legend:
Removed from v.2057  
changed lines
  Added in v.2058
  ViewVC Help
Powered by ViewVC 1.1.20