如何在Java代码中列出JBoss AS 7数据源属性？

Question

我正在运行JBoss AS 7.1.0.CR1b.我在standalone.xml中定义了几个数据源,例如

        <subsystem xmlns="urn:jboss:domain:datasources:1.0">
            <datasources>
                <datasource jndi-name="java:/MyDS" pool-name="MyDS_Pool" enabled="true" use-java-context="true" use-ccm="true">
                    <connection-url>some-url</connection-url>
                    <driver>the-driver</driver>
                    [etc]

一切正常.

我正在尝试访问我的代码中包含的信息 - 特别是connection-url和driver属性.

我尝试从JNDI获取数据源,正常情况下,但它似乎不提供对这些属性的访问:

// catches removed
InitialContext context;
DataSource dataSource = null;
context = new InitialContext();
dataSource = (DataSource) context.lookup(jndi);

来自此数据源的Connection对象的ClientInfo和DatabaseMetadata也不包含这些粒度的JBoss属性.

我的代码将在容器中运行,并且数据源已经指定,因此所有代码都应该可用.我已经查看了IronJacamar接口org.jboss.jca.common.api.metadata.ds.DataSource及其实现类,这些接口似乎可以访问我需要的信息,但是我找不到有关如何使用容器内已部署的资源创建此类对象的任何信息(只有impl上的构造函数涉及手动输入所有属性).

JBoss AS 7的命令行界面允许您将数据源导航并列为目录系统.http://www.paykin.info/java/add-datasource-programaticaly-cli-jboss-7/提供了一篇关于如何使用我认为的Java Management API与子系统交互的优秀文章,但这似乎是涉及连接到目标JBoss服务器.我的代码已经在该服务器中运行,所以肯定必须有一个更简单的方法吗？

希望有人可以提供帮助.非常感谢.

Answer 1

你真正想做的是管理行动.最好的方法是使用可用的管理API.

这是一个简单的独立示例:

public class Main {

    public static void main(final String[] args) throws Exception {
        final List<ModelNode> dataSources = getDataSources();
        for (ModelNode dataSource : dataSources) {
            System.out.printf("Datasource: %s%n", dataSource.asString());
        }
    }

    public static List<ModelNode> getDataSources() throws IOException {
        final ModelNode request = new ModelNode();
        request.get(ClientConstants.OP).set("read-resource");
        request.get("recursive").set(true);
        request.get(ClientConstants.OP_ADDR).add("subsystem", "datasources");
        ModelControllerClient client = null;
        try {
            client = ModelControllerClient.Factory.create(InetAddress.getByName("127.0.0.1"), 9999);
            final ModelNode response = client.execute(new OperationBuilder(request).build());
            reportFailure(response);
            return response.get(ClientConstants.RESULT).get("data-source").asList();
        } finally {
            safeClose(client);
        }
    }

    public static void safeClose(final Closeable closeable) {
        if (closeable != null) try {
            closeable.close();
        } catch (Exception e) {
            // no-op
        }
    }


    private static void reportFailure(final ModelNode node) {
        if (!node.get(ClientConstants.OUTCOME).asString().equals(ClientConstants.SUCCESS)) {
            final String msg;
            if (node.hasDefined(ClientConstants.FAILURE_DESCRIPTION)) {
                if (node.hasDefined(ClientConstants.OP)) {
                    msg = String.format("Operation '%s' at address '%s' failed: %s", node.get(ClientConstants.OP), node.get(ClientConstants.OP_ADDR), node.get(ClientConstants.FAILURE_DESCRIPTION));
                } else {
                    msg = String.format("Operation failed: %s", node.get(ClientConstants.FAILURE_DESCRIPTION));
                }
            } else {
                msg = String.format("Operation failed: %s", node);
            }
            throw new RuntimeException(msg);
        }
    }
}

我能想到的另一种方法是添加依赖于服务器内部的模块.它可以完成,但我可能会首先使用管理API.