summaryrefslogtreecommitdiff
path: root/db-4.8.30/test/scr037/HashCursorTest.cs
diff options
context:
space:
mode:
authorJesse Morgan <jesse@jesterpm.net>2016-12-17 21:28:53 -0800
committerJesse Morgan <jesse@jesterpm.net>2016-12-17 21:28:53 -0800
commit54df2afaa61c6a03cbb4a33c9b90fa572b6d07b8 (patch)
tree18147b92b969d25ffbe61935fb63035cac820dd0 /db-4.8.30/test/scr037/HashCursorTest.cs
Berkeley DB 4.8 with rust build script for linux.
Diffstat (limited to 'db-4.8.30/test/scr037/HashCursorTest.cs')
-rw-r--r--db-4.8.30/test/scr037/HashCursorTest.cs237
1 files changed, 237 insertions, 0 deletions
diff --git a/db-4.8.30/test/scr037/HashCursorTest.cs b/db-4.8.30/test/scr037/HashCursorTest.cs
new file mode 100644
index 0000000..1dd4cfb
--- /dev/null
+++ b/db-4.8.30/test/scr037/HashCursorTest.cs
@@ -0,0 +1,237 @@
+/*-
+ * See the file LICENSE for redistribution information.
+ *
+ * Copyright (c) 2009 Oracle. All rights reserved.
+ *
+ */
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.IO;
+using System.Text;
+using System.Threading;
+using NUnit.Framework;
+using BerkeleyDB;
+
+namespace CsharpAPITest
+{
+ [TestFixture]
+ public class HashCursorTest
+ {
+ private string testFixtureName;
+ private string testFixtureHome;
+ private string testName;
+ private string testHome;
+
+ [TestFixtureSetUp]
+ public void RunBeforeTests()
+ {
+ testFixtureName = "HashCursorTest";
+ testFixtureHome = "./TestOut/" + testFixtureName;
+ }
+
+ [Test]
+ public void TestAddToLoc()
+ {
+ HashDatabase db;
+ HashCursor cursor;
+ KeyValuePair<DatabaseEntry, DatabaseEntry> pair;
+
+ testName = "TestAddToLoc";
+ testHome = testFixtureHome + "/" + testName;
+
+ Configuration.ClearDir(testHome);
+
+ /*
+ * Open a hash database and cursor and then
+ * add record("key", "data") into database.
+ */
+ GetHashDBAndCursor(testHome, testName, out db, out cursor);
+ AddOneByCursor(cursor);
+
+ /*
+ * Add the new record("key","data1") as the first
+ * of the data item of "key".
+ */
+ pair = new KeyValuePair<DatabaseEntry, DatabaseEntry>(
+ new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("key")),
+ new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("data1")));
+ cursor.Add(pair, Cursor.InsertLocation.FIRST);
+
+ /*
+ * Confirm that the new record is added as the first of
+ * the data item of "key".
+ */
+ cursor.Move(new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("key")), true);
+ Assert.AreEqual(ASCIIEncoding.ASCII.GetBytes("data1"),
+ cursor.Current.Value.Data);
+
+ cursor.Close();
+ db.Close();
+ }
+
+ [Test]
+ public void TestAddUnique()
+ {
+ HashDatabase db;
+ HashCursor cursor;
+ KeyValuePair<DatabaseEntry, DatabaseEntry> pair;
+
+ testName = "TestAddUnique";
+ testHome = testFixtureHome + "/" + testName;
+
+ Configuration.ClearDir(testHome);
+
+ // Open a database and cursor.
+ HashDatabaseConfig dbConfig = new HashDatabaseConfig();
+ dbConfig.Creation = CreatePolicy.IF_NEEDED;
+
+ /*
+ * To put no duplicate data, the database should be
+ * set to be sorted.
+ */
+ dbConfig.Duplicates = DuplicatesPolicy.SORTED;
+ db = HashDatabase.Open(
+ testHome + "/" + testName + ".db", dbConfig);
+ cursor = db.Cursor();
+
+ // Add record("key", "data") into database.
+ AddOneByCursor(cursor);
+
+ /*
+ * Fail to add duplicate record("key","data").
+ */
+ pair = new KeyValuePair<DatabaseEntry, DatabaseEntry>(
+ new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("key")),
+ new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("data")));
+ try
+ {
+ cursor.AddUnique(pair);
+ }
+ catch (KeyExistException)
+ {
+ }
+ finally
+ {
+ cursor.Close();
+ db.Close();
+ }
+ }
+
+ [Test]
+ public void TestDuplicate()
+ {
+ HashDatabase db;
+ HashCursor cursor, dupCursor;
+ KeyValuePair<DatabaseEntry, DatabaseEntry> pair;
+
+ testName = "TestDuplicate";
+ testHome = testFixtureHome + "/" + testName;
+
+ Configuration.ClearDir(testHome);
+
+ GetHashDBAndCursor(testHome, testName,
+ out db, out cursor);
+
+ /*
+ * Add a record("key", "data") by cursor and move
+ * the cursor to the current record.
+ */
+ AddOneByCursor(cursor);
+ cursor.Refresh();
+
+ //Duplicate a new cursor to the same position.
+ dupCursor = cursor.Duplicate(true);
+
+ // Overwrite the record.
+ dupCursor.Overwrite(new DatabaseEntry(
+ ASCIIEncoding.ASCII.GetBytes("newdata")));
+
+ // Confirm that the original data doesn't exist.
+ pair = new KeyValuePair<DatabaseEntry, DatabaseEntry>(
+ new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("key")),
+ new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("data")));
+ Assert.IsFalse(dupCursor.Move(pair, true));
+
+ dupCursor.Close();
+ cursor.Close();
+ db.Close();
+ }
+
+ [Test]
+ public void TestInsertToLoc()
+ {
+ HashDatabase db;
+ HashDatabaseConfig dbConfig;
+ HashCursor cursor;
+ DatabaseEntry data;
+ KeyValuePair<DatabaseEntry, DatabaseEntry> pair;
+ string dbFileName;
+
+ testName = "TestInsertToLoc";
+ testHome = testFixtureHome + "/" + testName;
+ dbFileName = testHome + "/" + testName + ".db";
+
+ Configuration.ClearDir(testHome);
+
+ // Open database and cursor.
+ dbConfig = new HashDatabaseConfig();
+ dbConfig.Creation = CreatePolicy.IF_NEEDED;
+
+ /*
+ * The database should be set to be unsorted to
+ * insert before/after a certain record.
+ */
+ dbConfig.Duplicates = DuplicatesPolicy.UNSORTED;
+ db = HashDatabase.Open(dbFileName, dbConfig);
+ cursor = db.Cursor();
+
+ // Add record("key", "data") into database.
+ AddOneByCursor(cursor);
+
+ /*
+ * Insert the new record("key","data1") after the
+ * record("key", "data").
+ */
+ data = new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("data1"));
+ cursor.Insert(data, Cursor.InsertLocation.AFTER);
+
+ /*
+ * Move the cursor to the record("key", "data") and
+ * confirm that the next record is the one just inserted.
+ */
+ pair = new KeyValuePair<DatabaseEntry, DatabaseEntry>(
+ new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("key")),
+ new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("data")));
+ Assert.IsTrue(cursor.Move(pair, true));
+ Assert.IsTrue(cursor.MoveNext());
+ Assert.AreEqual(ASCIIEncoding.ASCII.GetBytes("key"),
+ cursor.Current.Key.Data);
+ Assert.AreEqual(ASCIIEncoding.ASCII.GetBytes("data1"),
+ cursor.Current.Value.Data);
+
+ cursor.Close();
+ db.Close();
+ }
+
+ public void GetHashDBAndCursor(string home, string name,
+ out HashDatabase db, out HashCursor cursor)
+ {
+ string dbFileName = home + "/" + name + ".db";
+ HashDatabaseConfig dbConfig = new HashDatabaseConfig();
+ dbConfig.Creation = CreatePolicy.IF_NEEDED;
+ db = HashDatabase.Open(dbFileName, dbConfig);
+ cursor = db.Cursor();
+ }
+
+ public void AddOneByCursor(HashCursor cursor)
+ {
+ DatabaseEntry key, data;
+ KeyValuePair<DatabaseEntry, DatabaseEntry> pair;
+ key = new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("key"));
+ data = new DatabaseEntry(ASCIIEncoding.ASCII.GetBytes("data"));
+ pair = new KeyValuePair<DatabaseEntry,DatabaseEntry>(key, data);
+ cursor.Add(pair);
+ }
+ }
+}