Package org.xmlBlaster.contrib

Examples of org.xmlBlaster.contrib.I_Info

421
422
423
424
425
426
427
428
429
430
431
   public void testPublishWithMoveRelativeLockMode() {
      boolean deliverDat = true;
      boolean deliverGif = true;
      boolean absSubPath = false;
      I_Info prop = new PropertiesInfo(new Properties());
      prop.put("filewatcher.sent", "Sent");
      prop.put("filewatcher.discarded", "Discarded");
      prop.put("filewatcher.lockExtention", "*.lck");
      doPublish(prop, deliverDat, deliverGif, absSubPath);
   }
View Full Code Here
432
433
434
435
436
437
438
439
440
441
   public void testSimplePublishWithFilterLockMode() {
      boolean deliverDat = false;
      boolean deliverGif = true;
      boolean absSubPath = true;
      I_Info prop = new PropertiesInfo(new Properties());
      prop.put("filewatcher.fileFilter", "*.gif");
      prop.put("filewatcher.lockExtention", "*.lck");
      doPublish(prop, deliverDat, deliverGif, absSubPath);
   }
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
85
86
    * Configure database access.
    * @see TestCase#setUp()
    */
   protected void setUp() throws Exception {
      super.setUp();
      I_Info info = new PropertiesInfo(System.getProperties());
      this.pool = new DbPool();
      this.pool.init(info);
      String context = null; // shall be set to '/'
      info.put("dbs.table", "TEST_DB_STORAGE");
      this.dbStorage = new DbStorage(info, this.pool, context);
     
   }
View Full Code Here
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
    *
    */
   public final void testTableToWatchInfoStatic() {
      log.info("Start testTableToWatchInfoStatic");
     
      I_Info info = new PropertiesInfo(new Properties());
      // info.put("table.schema1.table1", null); does not work since info will no add this
      info.put("table.schema1.table1", "actions=IDU");
      info.put("table.schema1.table2", "actions=IDU,trigger=trigger2,sequence=10");
      info.put("table.schema1.table3", "actions=IDU,trigger=trigger3,sequence=155");
      info.put("table.schema1.table4", "actions=IDU,trigger=trigger4,sequence=6");
      info.put("table.schema1.table5", "actions=IDU,trigger=trigger5,sequence=13");
      info.put("tablesomethingother", "should be ignored");
      info.put("somethingother", "should be ignored");
      try {
         Connection conn = null;
         TableToWatchInfo[] tables = TableToWatchInfo.getTablesToWatch(conn, info);
         assertEquals("number of tables", 5, tables.length);
         assertEquals("table sequence #1", "table1", tables[0].getTable());
View Full Code Here
792
793
794
795
796
797
798
799
800
801
802
803
804
805
   public final void testTableToWatchInfoForAllToken() {
      String txt = "testTableToWatchInfoForAllToken";
      log.info("Start " + txt);
      try {
         SpecificHelper specificHelper = new SpecificHelper(System.getProperties());
         I_Info info = new PropertiesInfo(specificHelper.getProperties());
         I_DbPool dbPool = setUpDbPool(info);
         Connection conn = dbPool.reserve();
         info.put("table.XMLBLASTER.*", "");
         TableToWatchInfo[] tables = TableToWatchInfo.getTablesToWatch(conn, info);
         assertTrue("wrong number of tables", tables.length > 0);
         for (int i=0; i < tables.length; i++) {
            log.info(tables[i].toXml());
         }
View Full Code Here
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
   public final void testSearchableConfig() {
      log.info("Start testSearchableConfig");

      try {
         SpecificHelper specificHelper = new SpecificHelper(System.getProperties());
         I_Info info = new PropertiesInfo((Properties)specificHelper.getProperties().clone());
         info.put("replication.searchable.xmlBlaster.table1", "first, second, third, fourth");
         info.put("replication.searchable.XMLBLASTER.TABLE2", "FIRST,SECOND");
        
         DbPool pool = new DbPool();
         pool.init(info);
         info.putObject(DbWriter.DB_POOL_KEY, pool);
        
         SearchableConfig searchableConfig = new SearchableConfig();
         searchableConfig.init(info);
         info.putObject(SearchableConfig.NAME, searchableConfig);
        
         pool.update("drop table table1");
         String txt = "create table table1 (first VARCHAR(100), second VARCHAR(100), third blob, fifth VARCHAR(29), primary key(first))";
         pool.update(txt);
        
View Full Code Here
TOP

Related Classes of org.xmlBlaster.contrib.I_Info

  • org.xmlBlaster.contrib.db.DbPool
  • org.xmlBlaster.contrib.db.DbWaitingPool
  • org.xmlBlaster.contrib.dbwatcher.DbWatcher
  • org.xmlBlaster.contrib.dbwatcher.Example
  • org.xmlBlaster.contrib.dbwriter.DbWriter
  • org.xmlBlaster.contrib.dbwriter.DbWriterExample
  • org.xmlBlaster.contrib.dbwriter.info.SqlDescription
  • org.xmlBlaster.contrib.dbwriter.info.SqlInfo
  • org.xmlBlaster.contrib.dbwriter.SqlInfoParser
  • org.xmlBlaster.contrib.replication.impl.ReplManagerPlugin
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.