c-treeDB API for Java

Manage

Manage() provides data management functionality for your application and/or process.

Below is the code for Manage():

// Manage()

// Populates table and perform a simple query

static void Manage() throws IOException, CTException {

System.out.println("MANAGE");

// populate the tables with data

Add_CustomerMaster_Records();

Add_ItemMaster_Records();

Add_Transactions();

// display the orders and their items

Display_CustomerOrders();

Display_OrderItems();

}

// Add_CustomerMaster_Records()

// This function adds records to table CustomerMaster from an

// array of Strings

public static class CUSTOMER_DATA {

// struct members

public String number, zipcode, state, rating, name, address, city;

// struct constructor

public CUSTOMER_DATA(String number, String zipcode, String state, String rating, String name, String address, String city) {

this.number = number;

this.zipcode = zipcode;

this.state = state;

this.rating = rating;

this.name = name;

this.address = address;

this.city = city;

}

};

static void Add_CustomerMaster_Records() throws IOException {

CUSTOMER_DATA[] data = new CUSTOMER_DATA[4];

data[0] = new CUSTOMER_DATA("1000", "92867", "CA", "1", "Bryan Williams", "2999 Regency", "Orange");

data[1] = new CUSTOMER_DATA("1001", "61434", "CT", "1", "Michael Jordan", "13 Main", "Harford");

data[2] = new CUSTOMER_DATA("1002", "73677", "GA", "1", "Joshua Brown", "4356 Cambridge", "Atlanta");

data[3] = new CUSTOMER_DATA("1003", "10034", "MO", "1", "Keyon Dooling", "19771 Park Avenue", "Columbia");

int nRecords = data.length;

Delete_Records(recordCustMast);

System.out.println("\tAdd records in table CustomerMaster...");

try {

// start a transaction

MySession.Begin();

for (int i = 0; i < nRecords; i++) {

recordCustMast.Clear();

// populate record buffer with data

recordCustMast.SetFieldAsString(0, data[i].number);

recordCustMast.SetFieldAsString(1, data[i].zipcode);

recordCustMast.SetFieldAsString(2, data[i].state);

recordCustMast.SetFieldAsString(3, data[i].rating);

recordCustMast.SetFieldAsString(4, data[i].name);

recordCustMast.SetFieldAsString(5, data[i].address);

recordCustMast.SetFieldAsString(6, data[i].city);

// add record

recordCustMast.Write();

}

// commit transaction

MySession.Commit();

} catch (CTException E) {

Handle_Exception(E);

}

// Add_ItemMaster_Records()

// This function adds records to table ItemMaster from an

// array of Strings

public static class ITEM_DATA {

// struct members

public int weight;

public BigDecimal price;

public String itemnum, description;

// struct constructor

public ITEM_DATA(int weight, BigDecimal price, String itemnum, String description) {

this.weight = weight;

this.price = price;

this.itemnum = itemnum;

this.description = description;

}

};

static void Add_ItemMaster_Records() throws IOException {

ITEM_DATA[] data = new ITEM_DATA[4];

data[0] = new ITEM_DATA(10, new BigDecimal("19.95"), "1", "Hammer");

data[1] = new ITEM_DATA(3, new BigDecimal("9.99"), "2", "Wrench");

data[2] = new ITEM_DATA(4, new BigDecimal("16.59"), "3", "Saw");

data[3] = new ITEM_DATA(1, new BigDecimal("3.98"), "4", "Pliers");

int nRecords = data.length;

Delete_Records(recordItemMast);

System.out.println("\tAdd records in table ItemMaster...");

try {

// start a transaction

MySession.Begin();

for (int i = 0; i < nRecords; i++) {

recordItemMast.Clear();

// populate record buffer with data

recordItemMast.SetFieldAsInt(0, data[i].weight);

recordItemMast.SetFieldAsBigDecimal(1, data[i].price);

recordItemMast.SetFieldAsString(2, data[i].itemnum);

recordItemMast.SetFieldAsString(3, data[i].description);

// add record

recordItemMast.Write();

}

// commit transaction

MySession.Commit();

} catch (CTException E) {

Handle_Exception(E);

}

// Delete_Records()

// This function deletes all the records in the table

static void Delete_Records(CTRecord record) throws IOException {

boolean found;

System.out.println("\tDelete records...");

try {

// write lock required for transaction updates

record.Lock(LOCK_MODE.WRITE);

// start a transaction

record.Begin();

// read first record

found = record.First();

while (found) // while records are found

{

// delete record

record.Delete();

// read next record

found = record.Next();

}

// commit transaction

record.Commit();

// free locks

record.Unlock();

} catch (CTException E) {

Handle_Exception(E);

}

// Add_Transactions()

// Add an Order and associated Items "as a transaction" to their

// respective tables. A transaction is committed or aborted if the

// customer number on the order is confirmed valid. Likewise each

// item in the order is verified to be a valid item. SavePoints are

// established as an order is processed, allowing a transaction to

// rollback to the previously verified item

public static class ORDER_DATA {

// struct members

public Calendar orderdate, promdate;

public String ordernum, custnum;

// struct constructor

public ORDER_DATA(Calendar orderdate, Calendar promdate, String ordernum, String custnum) {

this.orderdate = orderdate;

this.promdate = promdate;

this.ordernum = ordernum;

this.custnum = custnum;

}

};

public static class ORDERITEM_DATA {

// struct members

public String ordernum;

public int seqnumber, quantity;

public String itemnum;

// struct constructor

public ORDERITEM_DATA(String ordernum, int seqnumber, int quantity, String itemnum) {

this.ordernum = ordernum;

this.seqnumber = seqnumber;

this.quantity = quantity;

this.itemnum = itemnum;

}

};

static void Add_Transactions() throws IOException, CTException {

ORDER_DATA[] orders = new ORDER_DATA[3];

Calendar orddate0 = Calendar.getInstance();

Calendar promdate0 = Calendar.getInstance();