Package org.entityfs.support.log

Examples of org.entityfs.support.log.StdOutLogAdapter

86
87
88
89
90
91
92
93
94
95
96
    return createDbUsingFiles(files[0], files[1], truncate(files[2], howMuchToTruncate));
  }

  private LoggingTransactionalDatabase<Character, Character, Long> createCharacterDbUsingFiles(EFile f, EFile treef, EFile logf)
  {
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    lah.setLevel(Level.SEVERE);
    DatabaseBackend<Character, Character, Long> backend = new ConstantRecordSizeHeapBackend<Character, Character>(f, false, CharacterNullSerializer.INSTANCE, CharacterSerializer.INSTANCE, 0, 8192, lah);
    NodeRepository<Character> nr = new LruCacheNodeRepository<Character, Long>(new FileBackedNodeRepository<Character, Long>(treef, false, 0, new NumberOfRecordsNodeSizeStrategy(2), true, CharacterNullSerializer.INSTANCE, LongSerializer.INSTANCE, 4, 8192, null, lah), 10);
    BPlusTree<Character, Long> tree = new BPlusTree<Character, Long>(nr, lah);
    backend = new BPlusTreeIndexBackend<Character, Character, Character, Long>(backend, false, tree, CharacterToCharacterHasher.INSTANCE, lah);
View Full Code Here
39
40
41
42
43
44
45
46
47
48
49
{
  private final Map<Database<?, ?>, EFile[]> m_dbFiles = new HashMap<Database<?, ?>, EFile[]>();

  private LoggingTransactionalDatabase<String, String, Long> createDbUsingFiles(EFile f, EFile logf)
  {
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    lah.setLevel(Level.SEVERE);
    HeapBackend<String, String> backend = new HeapBackend<String, String>(f, false, StringNullSerializer.INSTANCE, StringSerializer.INSTANCE, 0, 8192, lah);
    LoggingTransactionalDatabase<String, String, Long> res = new LoggingTransactionalDatabase<String, String, Long>(backend, logf, StringNullSerializer.INSTANCE, StringSerializer.INSTANCE, lah);
    m_dbFiles.put(res, new EFile[] { f, logf });
    return res;
View Full Code Here
52
53
54
55
56
57
58
59
60
61
  @Override
  protected ConstantRecordSizeBPlusTreeBackend<Integer, Long> createBackend()
  {
    File dbFile = FileSupport.createTempFile();
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    ConstantRecordSizeBPlusTreeBackend<Integer, Long> res = new ConstantRecordSizeBPlusTreeBackend<Integer, Long>(new LruCacheNodeRepository<Integer, Long>(new FileBackedNodeRepository<Integer, Long>(new ReadWritableFileAdapter(dbFile), false, 0, new NumberOfRecordsNodeSizeStrategy(2), true, IntegerNullSerializer.INSTANCE, LongSerializer.INSTANCE, 4, 8192, null, lah), 10), false, lah);
    m_dbFiles.put(res, dbFile);
    return res;
  }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
  @Override
  protected ConstantRecordSizeBPlusTreeBackend<Character, Character> createCharacterBackend()
  {
    File dbFile = FileSupport.createTempFile();
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    ConstantRecordSizeBPlusTreeBackend<Character, Character> res = new ConstantRecordSizeBPlusTreeBackend<Character, Character>(new LruCacheNodeRepository<Character, Character>(new FileBackedNodeRepository<Character, Character>(new ReadWritableFileAdapter(dbFile), false, 0, new NumberOfRecordsNodeSizeStrategy(2), true, CharacterNullSerializer.INSTANCE, CharacterSerializer.INSTANCE, 4, 8192, null, lah), 10), false, lah);
    m_dbFiles.put(res, dbFile);
    return res;
  }
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
  {
    File f = FileSupport.createTempFile();
    FileBackedNodeRepository<Integer, Long> fbnr = null;
    try
    {
      LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
      fbnr = new FileBackedNodeRepository<Integer, Long>(new ReadWritableFileAdapter(f), false, 0, new NumberOfRecordsNodeSizeStrategy(2), false, IntegerNullSerializer.INSTANCE, LongSerializer.INSTANCE, 4, 8192, null, lah);
      new ConstantRecordSizeBPlusTreeBackend<Integer, Long>(fbnr, false, lah).close();
      fail();
    }
    catch (IllegalArgumentException e)
View Full Code Here
1553
1554
1555
1556
1557
1558
1559
1560
1561
1562
1563
    else
    {
      prepareTestData();
    }

    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());

    List<TestConfiguration<?, ?>> testConfigurations = createTestConfigurations();
    for (TestConfiguration<?, ?> tc : testConfigurations)
    {
      if (tc == null)
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
  @Test
  public void testExTransaction() throws IOException
  {
    String codePrefix = "org.helidb.txn.TransactionalDatabase<String, String> db1 = (org.helidb.txn.TransactionalDatabase<String, String>) args[0];\r\norg.helidb.txn.TransactionalDatabase<String, String> db2 = (org.helidb.txn.TransactionalDatabase<String, String>) args[1];\r\n";
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    File f1 = FileSupport.createTempFile();
    File f1l = FileSupport.createTempFile();
    File f2 = FileSupport.createTempFile();
    File f2l = FileSupport.createTempFile();
    try
View Full Code Here
275
276
277
278
279
280
281
282
283
284
285
  }

  @Test
  public void testUsingCursor() throws IOException
  {
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    Database<Integer, String> db = null;
    File f = FileSupport.createTempFile();
    File indf = FileSupport.createTempFile();
    try
    {
View Full Code Here
48
49
50
51
52
53
54
55
56
  @Override
  protected HeapBackend<String, String> createBackend()
  {
    File dbFile = FileSupport.createTempFile();
    // Set a ridiculously low buffer size
    HeapBackend<String, String> res = new HeapBackend<String, String>(new ReadWritableFileAdapter(dbFile), false, StringSerializer.INSTANCE, StringSerializer.INSTANCE, 0L, 4, new LogAdapterHolder(new StdOutLogAdapter()));
    m_dbFiles.put(res, dbFile);
    return res;
  }
View Full Code Here
39
40
41
42
43
44
45
46
47
48
49
{
  private final Map<Database<?, ?>, Object[]> m_dbFiles = new HashMap<Database<?, ?>, Object[]>();

  private LoggingTransactionalDatabase<String, String, String> createDbUsingFiles(Map<String, String> m, EFile logf)
  {
    LogAdapterHolder lah = new LogAdapterHolder(new StdOutLogAdapter());
    lah.setLevel(Level.SEVERE);
    MapBackend<String, String> backend = new MapBackend<String, String>(m, StringNullSerializer.INSTANCE, StringSerializer.INSTANCE, lah);
    LoggingTransactionalDatabase<String, String, String> res = new LoggingTransactionalDatabase<String, String, String>(backend, logf, StringNullSerializer.INSTANCE, StringSerializer.INSTANCE, lah);
    m_dbFiles.put(res, new Object[] { m, logf });
    return res;
View Full Code Here
TOP

Related Classes of org.entityfs.support.log.StdOutLogAdapter

  • org.helidb.backend.bpluscrs.ConstantRecordSizeBPlusTreeBackendTest
  • org.helidb.backend.cache.lru.LruCacheBackendOnConstantRecordSizeHeapBackendTest
  • org.helidb.backend.cache.lru.LruCacheBackendOnHeapBackendTest
  • org.helidb.backend.heap.HeapBackendTest
  • org.helidb.backend.heapcrs.ConstantRecordSizeHeapBackendTest
  • org.helidb.backend.impl.map.MapBackendTest
  • org.helidb.backend.index.bplus.BPlusTreeIndexBackendOnConstantRecordSizeHeapBackendTest
  • org.helidb.backend.index.bplus.BPlusTreeIndexBackendOnHeapBackendTest
  • org.helidb.doc.ProgrammersGuideExamplesTest
  • org.helidb.impl.txn.log.LoggingTxnDbOnConstantRecordSizeBPlusTreeBackendTest
    • 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.