dbdispatcher.java

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

	{
		__db_re_len_reply reply = new __db_re_len_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_re_len(this, args, reply);
		return reply;
	}

	public  __db_re_pad_reply __DB_db_re_pad_4001(__db_re_pad_msg args)
	{
		__db_re_pad_reply reply = new __db_re_pad_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.set_re_pad(this, args, reply);
		return reply;
	}

	public  __db_stat_reply __DB_db_stat_4001(__db_stat_msg args)
	{
		__db_stat_reply reply = new __db_stat_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.stat(this, args, reply);
		return reply;
	}

	public  __db_sync_reply __DB_db_sync_4001(__db_sync_msg args)
	{
		__db_sync_reply reply = new __db_sync_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.sync(this, args, reply);
		return reply;
	}

	public  __db_truncate_reply __DB_db_truncate_4001(__db_truncate_msg args)
	{
		__db_truncate_reply reply = new __db_truncate_reply();
		RpcDb rdb = getDb(args.dbpcl_id);
		if (rdb == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdb.truncate(this, args, reply);
		return reply;
	}

	//// Cursor methods

	public  __dbc_close_reply __DB_dbc_close_4001(__dbc_close_msg args)
	{
		__dbc_close_reply reply = new __dbc_close_reply();
		RpcDbc rdbc = getCursor(args.dbccl_id);
		if (rdbc == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbc.close(this, args, reply);
		return reply;
	}

	public  __dbc_count_reply __DB_dbc_count_4001(__dbc_count_msg args)
	{
		__dbc_count_reply reply = new __dbc_count_reply();
		RpcDbc rdbc = getCursor(args.dbccl_id);
		if (rdbc == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbc.count(this, args, reply);
		return reply;
	}

	public  __dbc_del_reply __DB_dbc_del_4001(__dbc_del_msg args)
	{
		__dbc_del_reply reply = new __dbc_del_reply();
		RpcDbc rdbc = getCursor(args.dbccl_id);
		if (rdbc == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbc.del(this, args, reply);
		return reply;
	}

	public  __dbc_dup_reply __DB_dbc_dup_4001(__dbc_dup_msg args)
	{
		__dbc_dup_reply reply = new __dbc_dup_reply();
		RpcDbc rdbc = getCursor(args.dbccl_id);
		if (rdbc == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbc.dup(this, args, reply);
		return reply;
	}

	public  __dbc_get_reply __DB_dbc_get_4001(__dbc_get_msg args)
	{
		__dbc_get_reply reply = new __dbc_get_reply();
		RpcDbc rdbc = getCursor(args.dbccl_id);
		if (rdbc == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbc.get(this, args, reply);
		return reply;
	}

	public  __dbc_pget_reply __DB_dbc_pget_4001(__dbc_pget_msg args) {
		__dbc_pget_reply reply = new __dbc_pget_reply();
		RpcDbc rdbc = getCursor(args.dbccl_id);
		if (rdbc == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbc.pget(this, args, reply);
		return reply;
	}

	public  __dbc_put_reply __DB_dbc_put_4001(__dbc_put_msg args) {
		__dbc_put_reply reply = new __dbc_put_reply();
		RpcDbc rdbc = getCursor(args.dbccl_id);
		if (rdbc == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbc.put(this, args, reply);
		return reply;
	}

	//// Environment methods

	public  __env_cachesize_reply __DB_env_cachesize_4001(__env_cachesize_msg args)
	{
		__env_cachesize_reply reply = new __env_cachesize_reply();
		RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
		if (rdbenv == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbenv.set_cachesize(this, args, reply);
		return reply;
	}

	public  __env_close_reply __DB_env_close_4001(__env_close_msg args)
	{
		__env_close_reply reply = new __env_close_reply();
		RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
		if (rdbenv == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbenv.close(this, args, reply);
		return reply;
	}

	public  __env_create_reply __DB_env_create_4001(__env_create_msg args)
	{
		__env_create_reply reply = new __env_create_reply();
		RpcDbEnv rdbenv = new RpcDbEnv();
		rdbenv.create(this, args, reply);
		return reply;
	}

	public  __env_dbremove_reply __DB_env_dbremove_4001(__env_dbremove_msg args)
	{
		__env_dbremove_reply reply = new __env_dbremove_reply();
		RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
		if (rdbenv == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbenv.dbremove(this, args, reply);
		return reply;
	}

	public  __env_dbrename_reply __DB_env_dbrename_4001(__env_dbrename_msg args)
	{
		__env_dbrename_reply reply = new __env_dbrename_reply();
		RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
		if (rdbenv == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbenv.dbrename(this, args, reply);
		return reply;
	}

	public  __env_encrypt_reply __DB_env_encrypt_4001(__env_encrypt_msg args)
	{
		__env_encrypt_reply reply = new __env_encrypt_reply();
		RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
		if (rdbenv == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbenv.set_encrypt(this, args, reply);
		return reply;
	}

	public  __env_flags_reply __DB_env_flags_4001(__env_flags_msg args)
	{
		__env_flags_reply reply = new __env_flags_reply();
		RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
		if (rdbenv == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbenv.set_flags(this, args, reply);
		return reply;
	}

	public  __env_open_reply __DB_env_open_4001(__env_open_msg args)
	{
		__env_open_reply reply = new __env_open_reply();
		RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
		if (rdbenv == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbenv.open(this, args, reply);
		return reply;
	}

	public  __env_remove_reply __DB_env_remove_4001(__env_remove_msg args)
	{
		__env_remove_reply reply = new __env_remove_reply();
		RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
		if (rdbenv == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbenv.remove(this, args, reply);
		return reply;
	}

	//// Transaction methods

	public  __txn_abort_reply __DB_txn_abort_4001(__txn_abort_msg args)
	{
		__txn_abort_reply reply = new __txn_abort_reply();
		RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
		if (rdbtxn == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbtxn.abort(this, args, reply);
		return reply;
	}

	public  __txn_begin_reply __DB_txn_begin_4001(__txn_begin_msg args)
	{
		__txn_begin_reply reply = new __txn_begin_reply();
		RpcDbTxn rdbtxn = new RpcDbTxn(getEnv(args.dbenvcl_id), null);
		rdbtxn.begin(this, args, reply);
		return reply;
	}

	public  __txn_commit_reply __DB_txn_commit_4001(__txn_commit_msg args)
	{
		__txn_commit_reply reply = new __txn_commit_reply();
		RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
		if (rdbtxn == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbtxn.commit(this, args, reply);
		return reply;
	}

	public  __txn_discard_reply __DB_txn_discard_4001(__txn_discard_msg args)
	{
		__txn_discard_reply reply = new __txn_discard_reply();
		RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
		if (rdbtxn == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbtxn.discard(this, args, reply);
		return reply;
	}

	public  __txn_prepare_reply __DB_txn_prepare_4001(__txn_prepare_msg args)
	{
		__txn_prepare_reply reply = new __txn_prepare_reply();
		RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
		if (rdbtxn == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbtxn.prepare(this, args, reply);
		return reply;
	}

	public  __txn_recover_reply __DB_txn_recover_4001(__txn_recover_msg args)
	{
		__txn_recover_reply reply = new __txn_recover_reply();
		RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
		if (rdbenv == null)
			reply.status = Db.DB_NOSERVER_ID;
		else
			rdbenv.txn_recover(this, args, reply);
		return reply;
	}
}