datasource - 如何在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 接口(interface) org.jboss.jca.common.api.metadata.ds.DataSource 及其实现类，这些似乎可以访问我需要的信息，但是我找不到任何关于如何使用容器中已部署的资源创建此类对象的信息(只有 impl 上的构造函数涉及手动输入所有属性)。

JBoss AS 7 的命令行界面允许您以目录系统的形式导航和列出数据源。 http://www.paykin.info/java/add-datasource-programaticaly-cli-jboss-7/提供了一篇关于如何使用我认为的 Java 管理 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。