diff --git a/mgmt-create-ds/pom.xml b/mgmt-create-ds/pom.xml index 28e2f4b69f..971d8776dd 100644 --- a/mgmt-create-ds/pom.xml +++ b/mgmt-create-ds/pom.xml @@ -46,10 +46,10 @@ - - org.jboss.as - jboss-as-controller-client - 7.1.0.Beta1b + + org.jboss.as + jboss-as-controller-client + 7.1.0.Beta1b org.jboss.as @@ -61,7 +61,7 @@ - mgmt-server-status + mgmt-server-create-ds/finalName> @@ -91,4 +91,4 @@ - + diff --git a/mgmt-create-ds/src/main/java/org/jboss/as/quickstarts/mgmt/Client.java b/mgmt-create-ds/src/main/java/org/jboss/as/quickstarts/mgmt/Client.java index 3043a3e4d6..783f849b65 100644 --- a/mgmt-create-ds/src/main/java/org/jboss/as/quickstarts/mgmt/Client.java +++ b/mgmt-create-ds/src/main/java/org/jboss/as/quickstarts/mgmt/Client.java @@ -18,8 +18,10 @@ public class Client { public static void main(String[] args) throws Exception { + //ModelControllerClient client = ModelControllerClient.Factory.create( + // InetAddress.getByName("127.0.0.1"), 9999, DemoAuthentication.getCallbackHandler()); ModelControllerClient client = ModelControllerClient.Factory.create( - InetAddress.getByName("10.32.69.24"), 9999, DemoAuthentication.getCallbackHandler()); + InetAddress.getByName("127.0.0.1"), 9999); try { String dsname = "REPLACE_WITH_PROPERTY"; @@ -29,10 +31,10 @@ public static void main(String[] args) throws Exception op.get("address").add("subsystem", "datasources").add("data-source", dsname); op.get("jndi-name").set("java:jboss/datasources/" + dsname); - //op.get("driver-name").set("mysql"); - op.get("driver-name").set("postgresql-8.4-703.jdbc4.jar"); + op.get("driver-name").set("mysql"); + //op.get("driver-name").set("postgresql-8.4-703.jdbc4.jar"); op.get("pool-name").set("TestDS"); - op.get("connection-url").set("jdbc:postgresql://localhost/test"); + op.get("connection-url").set("jdbc:mysql://localhost/demo"); op.get("max-pool-size").set(10); op.get("min-pool-size").set(5); @@ -68,6 +70,26 @@ public static void main(String[] args) throws Exception op = new ModelNode(); op.get("operation").set("enable"); op.get("address").add("subsystem", "datasources").add("data-source", dsname); + result = client.execute( + new ModelNode() + .get("operation").set("enable") + .get("address") + .add("subsystem", "datasources") + .add("data-source", dsname) + ); + + op = new ModelNode(); + op.get("operation").set("write-attribute"); + op.get("address").add("subsystem", "datasources").add("data-source", dsname); + op.get("name").set("max-pool-size"); + op.get("value").set("20"); + result = client.execute(op); + + op = new ModelNode(); + op.get("operation").set("write-attribute"); + op.get("address").add("subsystem", "datasources").add("data-source", dsname); + op.get("name").set("min-pool-size"); + op.get("value").set("10"); result = client.execute(op); diff --git a/mgmt-create-ds/src/main/java/org/jboss/as/quickstarts/mgmt/DemoAuthentication.java b/mgmt-create-ds/src/main/java/org/jboss/as/quickstarts/mgmt/DemoAuthentication.java index 1932f7065c..5db59e586d 100644 --- a/mgmt-create-ds/src/main/java/org/jboss/as/quickstarts/mgmt/DemoAuthentication.java +++ b/mgmt-create-ds/src/main/java/org/jboss/as/quickstarts/mgmt/DemoAuthentication.java @@ -29,8 +29,8 @@ public class DemoAuthentication { // for this reason we cache the entered values to allow for re-use without pestering the end // user. private boolean promptShown = false; - private String userName = null; - private char[] password = null; + private String userName = "user1"; + private char[] password = "pwd1".toCharArray(); private DemoAuthentication() { } diff --git a/mgmt-create-xa-ds/pom.xml b/mgmt-create-xa-ds/pom.xml new file mode 100644 index 0000000000..d3ec79d56b --- /dev/null +++ b/mgmt-create-xa-ds/pom.xml @@ -0,0 +1,96 @@ + + + 4.0.0 + + org.jboss.as.quickstarts + mgmt-create-xa-ds + 1.0 + jar + JBoss AS Quickstarts: Create a XA Datasource through the Mgmt API + + http://jboss.org/jbossas + + + GNU Lesser General Public License + http://www.gnu.org/copyleft/lesser.html + repo + + + + + + + UTF-8 + + + + + + + + org.jboss.spec + jboss-javaee-6.0 + 3.0.0.Beta1 + pom + import + + + + + + + org.jboss.as + jboss-as-controller-client + 7.1.0.Beta1b + + + org.jboss.as + jboss-as-controller + 7.1.0.Beta1b + + + + + + mgmt-create-xa-ds + + + + maven-compiler-plugin + 2.3.1 + + 1.6 + 1.6 + + + + org.codehaus.mojo + exec-maven-plugin + 1.2.1 + + + test + + java + + + org.jboss.as.quickstarts.mgmt.Client + + + + + + + + \ No newline at end of file diff --git a/mgmt-create-xa-ds/src/main/java/org/jboss/as/quickstarts/mgmt/Client.java b/mgmt-create-xa-ds/src/main/java/org/jboss/as/quickstarts/mgmt/Client.java new file mode 100644 index 0000000000..9524598e5b --- /dev/null +++ b/mgmt-create-xa-ds/src/main/java/org/jboss/as/quickstarts/mgmt/Client.java @@ -0,0 +1,75 @@ +package org.jboss.as.quickstarts.mgmt; + +import org.jboss.as.controller.client.ModelControllerClient; +import org.jboss.dmr.ModelNode; + +import java.net.InetAddress; + +/** + * Red Hat GmbH - Global Professional Services (GPS) + *

+ * Author: Juergen Hoffmann + * Date: 13.02.12 + * Time: 09:51 + */ +public class Client +{ + public static void main(String[] args) throws Exception + { + ModelControllerClient client = ModelControllerClient.Factory.create( + InetAddress.getByName("127.0.0.1"), 9999); + + try{ + String dsname = "REPLACE_WITH_PROPERTY"; + ModelNode op = new ModelNode(); + op.get("operation").set("add"); + + op.get("address").add("subsystem", "datasources").add("xa-data-source", dsname); + + op.get("jndi-name").set("java:jboss/datasources/" + "XA" + dsname); + op.get("xa-datasource-class").set("com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"); + op.get("driver-name").set("mysql"); + op.get("use-java-context").set("true"); + op.get("pool-name").set("TestXADS"); + op.get("xa-resource-timeout").set(3600); + op.get("jta").set(true); + + op.get("max-pool-size").set(10); + op.get("min-pool-size").set(5); + + ModelNode result = client.execute(op); + + System.out.println(result.toString()); + + op = new ModelNode(); + op.get("operation").set("add"); + op.get("address").add("subsystem","datasources").add("xa-data-source", dsname).add("xa-datasource-properties", "URL"); + op.get("value").set("jdbc:mysql://localhost/demo"); + + result = client.execute(op); + + System.out.println(result.toString()); + + op = new ModelNode(); + op.get("operation").set("add"); + op.get("address").add("subsystem","datasources").add("xa-data-source", dsname).add("xa-datasource-properties", "User"); + op.get("value").set("demo"); + + result = client.execute(op); + + System.out.println(result.toString()); + + op = new ModelNode(); + op.get("operation").set("add"); + op.get("address").add("subsystem","datasources").add("xa-data-source", dsname).add("xa-datasource-properties", "Password"); + op.get("value").set("demo"); + + result = client.execute(op); + + System.out.println(result.toString()); + } + finally { + client.close(); + } + } +}