--- parser3/src/classes/hashfile.C	2001/10/24 11:06:26	1.8
+++ parser3/src/classes/hashfile.C	2001/10/27 10:14:45	1.12
@@ -4,7 +4,7 @@
 	Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com)
 	Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)
 
-	$Id: hashfile.C,v 1.8 2001/10/24 11:06:26 parser Exp $
+	$Id: hashfile.C,v 1.12 2001/10/27 10:14:45 paf Exp $
 */
 
 #include "pa_config_includes.h"
@@ -37,17 +37,12 @@ static void _open(Request& r, const Stri
 	Pool& pool=r.pool();
 	VHashfile& self=*static_cast<VHashfile *>(r.self);
 	
-	// file_spec
-	const String &file_spec=params->as_string(0, "filename must be string");
-
-	self.set_connection(
-		DB_manager->get_connection(
-			r.absolute(file_spec), 
-			method_name)
+	self.assign(
+		params->as_string(0, "DB_HOME must be string"), 
+		params->as_string(1, "filename must be string")
 	);
 }
 
-
 static void _transaction(Request& r, const String& method_name, MethodParams *params) {
 	Pool& pool=r.pool();
 	VHashfile& self=*static_cast<VHashfile *>(r.self);
@@ -55,11 +50,11 @@ static void _transaction(Request& r, con
 	// body code
 	Value& body_code=params->as_junction(0, "body must be code");
 
-	// connection
-	DB_Connection& connection=self.get_connection(&method_name);
+	// table
+	DB_Table_ptr table_ptr=self.get_table_ptr(&method_name);
 
 	// transaction
-	Auto_transaction transaction(connection);
+	DB_Transaction transaction(pool, *table_ptr, self.current_transaction);
 
 	// execute body
 	try {
@@ -71,15 +66,6 @@ static void _transaction(Request& r, con
 	}
 }
 
-static void _clear(Request& r, const String& method_name, MethodParams *params) {
-	Pool& pool=r.pool();
-	
-	// file_spec
-	const String &file_spec=params->as_string(0, "filename must be string");
-
-	DB_manager->clear_dbfile(r.absolute(file_spec));
-}
-
 static void _hash(Request& r, const String& method_name, MethodParams *params) {
 	Pool& pool=r.pool();
 	VHashfile& self=*static_cast<VHashfile *>(r.self);
@@ -99,22 +85,19 @@ static void _cache(Request& r, const Str
 	double expires=params->as_double(1, "expires must be number", r);
 	Value& body_code=params->as_junction(2, "body must be code");
 
-	// connection
-	DB_Connection& connection=self.get_connection(&method_name);
-
 	// transaction
-	Auto_transaction transaction(connection);
+	DB_Transaction transaction(pool, *self.get_table_ptr(&method_name), self.current_transaction);
 
 	// execute body
 	try {
 		if(expires) { // 'expires' specified? try cached copy...
-			if(String *cached_body=connection.get(key)) { // have cached copy?
+			if(String *cached_body=transaction.get(key)) { // have cached copy?
 				r.write_assign_lang(*cached_body);
 				// happy with it
 				return;
 			}
 		} else // 'expires'=0, forget cached copy
-			connection.remove(key);
+			transaction.remove(key);
 
 		// save
 		Autosave_marked_to_cancel_cache saved(self);
@@ -125,7 +108,7 @@ static void _cache(Request& r, const Str
 		
 		// put it to cache if 'expires' specified & never called ^delete[]
 		if(expires && !self.marked_to_cancel_cache())
-			connection.put(key, processed_body.as_string(), time(0)+(time_t)expires);
+			transaction.put(key, processed_body.as_string(), time(0)+(time_t)expires);
 	} catch(...) { // process/commit problem
 		transaction.mark_to_rollback();
 		
@@ -142,10 +125,23 @@ static void _delete(Request& r, const St
 	else {
 		// key
 		const String &key=params->as_string(0, "key must be string");
-		// connection
-		DB_Connection& connection=self.get_connection(&method_name);
 		// remove
-		connection.remove(key);
+		self.get_table_ptr(&method_name)->remove(self.current_transaction, key);
+	}
+}
+
+static void _clear(Request& r, const String& method_name, MethodParams *) {
+	Pool& pool=r.pool();
+	VHashfile& self=*static_cast<VHashfile *>(r.self);
+	DB_Cursor cursor(
+		*self.get_table_ptr(&method_name), 
+		self.current_transaction, &method_name);
+
+	while(true) {
+		if(!cursor.move(DB_NEXT))
+			break;
+
+		cursor.remove(0/*flags*/);
 	}
 }
 
@@ -154,18 +150,18 @@ static void _delete(Request& r, const St
 MHashfile::MHashfile(Pool& apool) : Methoded(apool) {
 	set_name(*NEW String(pool(), HASH_CLASS_NAME));
 
-	// ^hashfile::open[filename]
-	add_native_method("open", Method::CT_DYNAMIC, _open, 1, 1);
+	// ^hashfile::open[db_home;filename]
+	add_native_method("open", Method::CT_DYNAMIC, _open, 2, 2);
 	// ^transaction{code}
 	add_native_method("transaction", Method::CT_DYNAMIC, _transaction, 1, 1);
-	// ^hashfile:clear[filename]
-	add_native_method("clear", Method::CT_STATIC, _clear, 1, 1);
 	// ^hash[]
 	add_native_method("hash", Method::CT_DYNAMIC, _hash, 0, 0);
 	// ^cache[key](seconds){code}
 	add_native_method("cache", Method::CT_DYNAMIC, _cache, 3, 3);
 	// ^hashfile.delete[key]
 	add_native_method("delete", Method::CT_DYNAMIC, _delete, 0, 1);
+	// ^hashfile.clear[]
+	add_native_method("clear", Method::CT_DYNAMIC, _clear, 0, 0);
 }
 
 // global variable