Package com.orientechnologies.orient.core.db.document

Examples of com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx.open()

1008
1009
1010
1011
1012
1013
1014
1015
1016
1017
1018
  }

  public void createInheritanceIndex() {
    ODatabaseDocument db = new ODatabaseDocumentTx(database.getURL());
    try {
      db.open("admin", "admin");

      if (!db.getMetadata().getSchema().existsClass("BaseTestClass")) {
        OClass baseClass = db.getMetadata().getSchema().createClass("BaseTestClass");
        OClass childClass = db.getMetadata().getSchema().createClass("ChildTestClass");
        OClass anotherChildClass = db.getMetadata().getSchema().createClass("AnotherChildTestClass");
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
  public void setUp() throws Exception {
    System.out.println("Create db");
    ODatabaseDocumentTx database = new ODatabaseDocumentTx(URL);

    if (database.exists()) {
      database.open("admin", "admin").drop();
    }

    database.create();

    database.getMetadata().getSchema().createClass(STUDENT_CLASS_NAME);
View Full Code Here
31
32
33
34
35
36
37
38
39
40
41
    if (ODatabaseHelper.existsDatabase(database, "plocal"))
      ODatabaseHelper.dropDatabase(database, "plocal");

    ODatabaseHelper.createDatabase(database, url);

    database.open("admin", "admin");

    for (int i = database.getClusters(); i < Short.MAX_VALUE; ++i) {
      System.out.println("Creating cluster: " + i);
      database.addCluster("cluster" + i);
      new ODocument().field("id", i).save("cluster" + i);
View Full Code Here
40
41
42
43
44
45
46
47
48
49
      database.addCluster("cluster" + i);
      new ODocument().field("id", i).save("cluster" + i);
    }
    database.close();

    database.open("admin", "admin");
    System.out.println("Total clusters: " + database.getClusters());
    database.close();
  }
}
View Full Code Here
505
506
507
508
509
510
511
512
513
514
515
      System.out.println("Exception: " + ex);
      throw ex;
    }

    ODatabaseDocumentTx database = new ODatabaseDocumentTx(URL);
    database.open("admin", "admin");

    OClass student = database.getMetadata().getSchema().createClass(STUDENT_CLASS_NAME);

    student.createProperty("counter", OType.INTEGER);
    student.createProperty("counter2", OType.INTEGER);
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
  private class NonTransactionalAdder implements Callable<Void> {
    public Void call() throws Exception {
      Thread.currentThread().setName("Adder - " + Thread.currentThread().getId());
      ODatabaseDocumentTx database = new ODatabaseDocumentTx(URL);
      database.open("admin", "admin");
      try {
        ODatabaseRecordThreadLocal.INSTANCE.set(database);
        countDownLatch.await();

        long value = createCounter.getAndIncrement();
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
  private class TransactionalAdder implements Callable<Void> {
    public Void call() throws Exception {
      Thread.currentThread().setName("TransactionalAdder - " + Thread.currentThread().getId());
      ODatabaseDocumentTx database = new ODatabaseDocumentTx(URL);
      database.open("admin", "admin");
      try {
        ODatabaseRecordThreadLocal.INSTANCE.set(database);
        countDownLatch.await();

        long value = transactionalCreateCounter.getAndIncrement();
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
      if (iCreate)
        db.create();
      else if (iOpen)
        throw new ODatabaseException("Database '" + url + "' not found");
    } else if (iOpen)
      db.open(user, password);

    return db;
  }

  /**
 
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
  @BeforeClass
  public void setUpClass() {
    final ODatabaseDocumentTx setup = new ODatabaseDocumentTx(url);

    if (setup.exists()) {
      setup.open("admin", "admin");
      setup.drop();
      setup.create();
    } else {
      setup.create();
    }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
  }

  public void testConcurrency() throws Exception {
    ODatabaseDocumentTx db = new ODatabaseDocumentTx(URL);
    if (db.exists()) {
      db.open("admin", "admin");
      db.drop();
    }

    db.create();
    for (int i = 0; i < 100; i++) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.