dbdispatcher.java

这是linux下运行的mysql软件包,可用于linux 下安装 php + mysql + apach 的网络配置

/*-
 * See the file LICENSE for redistribution information.
 *
 * Copyright (c) 2001-2002
 *      Sleepycat Software.  All rights reserved.
 *
 * $Id: DbDispatcher.java,v 1.5 2002/08/09 01:56:08 bostic Exp $
 */

package com.sleepycat.db.rpcserver;

import com.sleepycat.db.*;
import java.io.IOException;
import org.acplt.oncrpc.OncRpcException;

/**
 * Dispatcher for RPC messages for the Java RPC server.
 * These are hooks that translate between RPC msg/reply structures and
 * DB calls, which keeps the real implementation code in Rpc* classes cleaner.
 */
public abstract class DbDispatcher extends DbServerStub
{
	abstract int addEnv(RpcDbEnv rdbenv);
	abstract int addDb(RpcDb rdb);
	abstract int addTxn(RpcDbTxn rtxn);
	abstract int addCursor(RpcDbc rdbc);
	abstract void delEnv(RpcDbEnv rdbenv);
	abstract void delDb(RpcDb rdb);
	abstract void delTxn(RpcDbTxn rtxn);
	abstract void delCursor(RpcDbc rdbc);
	abstract RpcDbEnv getEnv(int envid);
	abstract RpcDb getDb(int dbid);
	abstract RpcDbTxn getTxn(int txnbid);
	abstract RpcDbc getCursor(int dbcid);

	public DbDispatcher() throws IOException, OncRpcException
	{
		super();
	}

	//// Db methods

	public  __db_associate_reply __DB_db_associate_4001(__db_associate_msg args)
	{
		__db_associate_reply reply = new __db_associate_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.associate(this, args, reply);
		return reply;
	}

	public  __db_bt_maxkey_reply __DB_db_bt_maxkey_4001(__db_bt_maxkey_msg args)
	{
		__db_bt_maxkey_reply reply = new __db_bt_maxkey_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_bt_maxkey(this, args, reply);
		return reply;
	}

	public  __db_bt_minkey_reply __DB_db_bt_minkey_4001(__db_bt_minkey_msg args)
	{
		__db_bt_minkey_reply reply = new __db_bt_minkey_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_bt_minkey(this, args, reply);
		return reply;
	}

	public  __db_close_reply __DB_db_close_4001(__db_close_msg args)
	{
		__db_close_reply reply = new __db_close_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.close(this, args, reply);
		return reply;
	}

	public  __db_create_reply __DB_db_create_4001(__db_create_msg args)
	{
		__db_create_reply reply = new __db_create_reply();
		RpcDb rdb = new RpcDb(getEnv(args.dbenvcl_id));
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.create(this, args, reply);
		return reply;
	}

	public  __db_cursor_reply __DB_db_cursor_4001(__db_cursor_msg args)
	{
		__db_cursor_reply reply = new __db_cursor_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.cursor(this, args, reply);
		return reply;
	}

	public  __db_del_reply __DB_db_del_4001(__db_del_msg args)
	{
		__db_del_reply reply = new __db_del_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.del(this, args, reply);
		return reply;
	}

	public  __db_encrypt_reply __DB_db_encrypt_4001(__db_encrypt_msg args)
	{
		__db_encrypt_reply reply = new __db_encrypt_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_encrypt(this, args, reply);
		return reply;
	}

	public  __db_extentsize_reply __DB_db_extentsize_4001(__db_extentsize_msg args)
	{
		__db_extentsize_reply reply = new __db_extentsize_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_q_extentsize(this, args, reply);
		return reply;
	}

	public  __db_flags_reply __DB_db_flags_4001(__db_flags_msg args)
	{
		__db_flags_reply reply = new __db_flags_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_flags(this, args, reply);
		return reply;
	}

	public  __db_get_reply __DB_db_get_4001(__db_get_msg args)
	{
		__db_get_reply reply = new __db_get_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.get(this, args, reply);
		return reply;
	}

	public  __db_h_ffactor_reply __DB_db_h_ffactor_4001(__db_h_ffactor_msg args)
	{
		__db_h_ffactor_reply reply = new __db_h_ffactor_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_h_ffactor(this, args, reply);
		return reply;
	}

	public  __db_h_nelem_reply __DB_db_h_nelem_4001(__db_h_nelem_msg args)
	{
		__db_h_nelem_reply reply = new __db_h_nelem_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_h_nelem(this, args, reply);
		return reply;
	}

	public  __db_join_reply __DB_db_join_4001(__db_join_msg args)
	{
		__db_join_reply reply = new __db_join_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.join(this, args, reply);
		return reply;
	}

	public  __db_key_range_reply __DB_db_key_range_4001(__db_key_range_msg args)
	{
		__db_key_range_reply reply = new __db_key_range_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.key_range(this, args, reply);
		return reply;
	}

	public  __db_lorder_reply __DB_db_lorder_4001(__db_lorder_msg args)
	{
		__db_lorder_reply reply = new __db_lorder_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_lorder(this, args, reply);
		return reply;
	}

	public  __db_open_reply __DB_db_open_4001(__db_open_msg args)
	{
		__db_open_reply reply = new __db_open_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.open(this, args, reply);
		return reply;
	}

	public  __db_pagesize_reply __DB_db_pagesize_4001(__db_pagesize_msg args)
	{
		__db_pagesize_reply reply = new __db_pagesize_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_pagesize(this, args, reply);
		return reply;
	}

	public  __db_pget_reply __DB_db_pget_4001(__db_pget_msg args)
	{
		__db_pget_reply reply = new __db_pget_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.pget(this, args, reply);
		return reply;
	}

	public  __db_put_reply __DB_db_put_4001(__db_put_msg args)
	{
		__db_put_reply reply = new __db_put_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.put(this, args, reply);
		return reply;
	}

	public  __db_remove_reply __DB_db_remove_4001(__db_remove_msg args)
	{
		__db_remove_reply reply = new __db_remove_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.remove(this, args, reply);
		return reply;
	}

	public  __db_rename_reply __DB_db_rename_4001(__db_rename_msg args)
	{
		__db_rename_reply reply = new __db_rename_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.rename(this, args, reply);
		return reply;
	}

	public  __db_re_delim_reply __DB_db_re_delim_4001(__db_re_delim_msg args)
	{
		__db_re_delim_reply reply = new __db_re_delim_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_re_delim(this, args, reply);
		return reply;
	}

	public  __db_re_len_reply __DB_db_re_len_4001(__db_re_len_msg args)