1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 2009, 2015 Oracle and/or its affiliates. All rights reserved.
*
*/
using System;
using System.Collections.Generic;
using System.Collections;
using System.Diagnostics;
using System.IO;
using System.Text;
using System.Runtime.Serialization.Formatters.Binary;
using BerkeleyDB;
namespace excs_getting_started {
public class DatabaseReader {
private MyDbs myDbs = null;
public DatabaseReader(MyDbs dbs) {
myDbs = dbs;
}
public void showItem(string locateItem) {
SecondaryCursor secCursor;
/* searchKey is the key to find in the secondary db. */
DatabaseEntry searchKey = new DatabaseEntry();
searchKey.Data = System.Text.Encoding.ASCII.GetBytes(locateItem);
/* Open a secondary cursor. */
secCursor = this.myDbs.ItemSecbtreeDB.SecondaryCursor();
/*
* Search for the secondary. The primary key/data pair
* associated with the given secondary key is stored in Current.
* In the presence of duplicate key values, the first data
* item in the set of duplicates is stored in Current.
*/
if (secCursor.Move(searchKey, true)) {
Inventory theInventory = new Inventory(
secCursor.Current.Value.Value.Data);
/* Display the record. */
displayInventory(theInventory);
/* Get each duplicate. */
while (secCursor.MoveNextDuplicate()) {
theInventory = new Inventory(
secCursor.Current.Value.Value.Data);
displayInventory(theInventory);
}
} else {
Console.WriteLine("Could not find itemname {0} ", locateItem);
Console.WriteLine();
Console.WriteLine();
return;
}
/* Close the cursor and the duplicate cursor. */
secCursor.Close();
}
public void showAllInventory() {
BTreeCursor cursor = myDbs.InventoryDB.Cursor();
Inventory theInventory;
while (cursor.MoveNext()) {
theInventory = new Inventory(cursor.Current.Value.Data);
displayInventory(theInventory);
}
cursor.Close();
}
public void displayInventory(Inventory theInventory) {
Console.WriteLine("Item: {0} ",theInventory.Itemname);
Console.WriteLine("SKU: {0} ", theInventory.Sku);
Console.WriteLine("Price per unit: {0} ", theInventory.Price);
Console.WriteLine("Quantity: {0} ", theInventory.Quantity);
Console.WriteLine("Category: {0} ", theInventory.Category);
Console.WriteLine("Contact: {0} ", theInventory.Vendor);
/* Display the associated Vendor information. */
displayVendor(theInventory);
}
private void displayVendor(Inventory theInventory) {
BinaryFormatter formatter = new BinaryFormatter();
DatabaseEntry foundVendor = new DatabaseEntry();
MemoryStream memStream;
Vendor theVendor;
foundVendor.Data = System.Text.Encoding.ASCII.GetBytes(
theInventory.Vendor);
try {
KeyValuePair<DatabaseEntry, DatabaseEntry> pair =
new KeyValuePair<DatabaseEntry, DatabaseEntry>();
string vendorData;
pair = this.myDbs.VendorDB.Get(foundVendor);
vendorData = System.Text.ASCIIEncoding.ASCII.GetString(
pair.Value.Data);
memStream = new MemoryStream(pair.Value.Data.Length);
memStream.Write(pair.Value.Data, 0, pair.Value.Data.Length);
/* Read from the begining of the stream. */
memStream.Seek(0, SeekOrigin.Begin);
theVendor = (Vendor)formatter.Deserialize(memStream);
memStream.Close();
System.Console.WriteLine("Vendor: {0}", theVendor.Name);
System.Console.WriteLine("Vendor Phone: {0}",
theVendor.PhoneNumber);
System.Console.Write("Vendor Address: {0}, ",theVendor.Street);
System.Console.Write("{0} ",theVendor.City);
System.Console.Write("{0} ",theVendor.State);
System.Console.WriteLine("{0} ",theVendor.Zipcode);
System.Console.WriteLine("Vendor Rep: {0}: {1}",
theVendor.SalesRep, theVendor.SalesRepPhone);
System.Console.WriteLine();
System.Console.WriteLine();
}
catch (Exception e) {
Console.WriteLine("displayVendor Error.");
Console.WriteLine(e.Message);
throw e;
}
}
}
}
|
