Peter Brown

This is as far as I got if anyone needs it, now re-assessing global transactions:

@Test public void testJob() throws Exception { AtomikosDataSourceBean dsb = (AtomikosDataSourceBean) context.getBean("uymDS"); SwitchAtomikosDataSource uymSwitch = (SwitchAtomikosDataSource) context.getBean("switchAtomikosDataSource"); // Default url Connection conn = null; Statement stmt = null; ResultSet rs = null; try { conn = dsb.getConnection(); stmt = conn.createStatement(); System.out.println("before 1st db: " + dsb.getXaProperties().getProperty("url")); rs = stmt.executeQuery("SELECT id FROM file"); while (rs.next()) { System.out.println("file id " + rs.getInt("id")); } stmt.close(); } finally { conn.close(); } String oldUrl = dsb.getXaProperties().getProperty("url"); String newUrl = "JTS"; // Check if no need to switch if (uymSwitch.needToSwitchDataSource(oldUrl, newUrl)) { dsb = uymSwitch.getNewUymDataSource(dsb, newUrl); } try { conn = dsb.getConnection(); stmt = conn.createStatement(); System.out.println("before 2nd db: " + dsb.getXaProperties().getProperty("url")); rs = stmt.executeQuery("SELECT id FROM file"); while (rs.next()) { System.out.println("file id " + rs.getInt("id")); } stmt.close(); } finally { conn.close(); } }

and it works.

I then setup an aop implementation that gets the needed oldurl from the datasource and newurl from a stepExecutionListener. The idea being that I get the first index of the stepExecutionListener array object in the aop proxy - close (if needed) and initialize with new url and the jdbcTemplate is none the wiser...

I then run the Spring Batch job and get the following:

INFO : com.atomikos.icatch.imp.BaseTransactionManager - createCompositeTransaction ( 300000 ): created new ROOT transaction with id tmdev0005400236 INFO : com.atomikos.jdbc.AbstractDataSourceBean - AtomikosDataSoureBean 'uymDS': close... dbName is: MFS_2013_Feb url is: jdbc:mysql://xxx.xxx.xxx.xxx:xxxx/MFS_2013_Feb?zeroDateTimeBehavior=convertToNull INFO : com.atomikos.jdbc.AbstractDataSourceBean - AtomikosDataSoureBean 'uymDS': init... INFO : com.atomikos.jdbc.AtomikosDataSourceBean - AtomikosDataSoureBean 'uymDS': initializing with [ xaDataSourceClassName=com.mysql.jdbc.jdbc2.optional.MysqlXADataSource, uniqueResourceName=uymDS, maxPoolSize=2, minPoolSize=2, borrowConnectionTimeout=30, maxIdleTime=60, reapTimeout=0, maintenanceInterval=60, testQuery=select 1, xaProperties=[autoReconnect=true,user=xxx,url=jdbc:mysql://xxx.xxx.xxx.xxx:xxxx/MFS_2013_Feb?zeroDateTimeBehavior=convertToNull,password=xxx,autoReconnectForPools=true,autoReconnectForConnectionPools=true,pinGlobalTxToPhysicalConnection=true] loginTimeout=0] INFO : com.atomikos.icatch.imp.TransactionServiceImp - Coordinator not recoverable: tmdev0005400219 INFO : com.atomikos.datasource.xa.XATransactionalResource - uymDS: refreshed XAResource INFO : com.k12knowledge.aop.SwitchDataSourceImpl - datasource switched from jdbc:mysql://xxx.xxx.xxx.xxx:xxxx/TEST_2012_Nov?zeroDateTimeBehavior=convertToNull to : jdbc:mysql://xxx.xxx.xxx.xxx:xxxx/MFS_2013_Feb?zeroDateTimeBehavior=convertToNull INFO : com.atomikos.jdbc.AbstractDataSourceBean - AtomikosDataSoureBean 'uymDS': getConnection ( null )... INFO : com.atomikos.jdbc.AbstractDataSourceBean - AtomikosDataSoureBean 'uymDS': init... WARN : com.atomikos.jdbc.AtomikosSQLException - Cannot initialize AtomikosDataSourceBean javax.naming.NamingException: Another resource already exists with name uymDS - pick a different name

[The 'createCompositeTransaction' and 'Coordinator not recoverable' are two lines I don't see on my test run.]

I have dug around in the Atomikos code and confirmed that Atomikos is removing the named resource on close.
I have tried setting lazy-init="false" with no change.
I have tried altering the properties file url on close thinking the init will re-read the properties file on init - no change.

Kinda want this Switching Datasources dynamically at runtime (I understand boneCP is not XA Transaction compliant)

Cheers

Hello,

This is a continuation of an earlier resolved thread - Datasource url database name not known until after a Batch step. I moved over to using the Atomikos connection pool and the url switch is not sticking. I can't get the AtomikosDataSourceBean to refresh or recognize the url change.

The xml config for the datasource bean is:
<util:properties id="uymDbProperties" location="classpath:/META-INF/uymdb.properties" /> <bean id="uymDS" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close"> <property name="uniqueResourceName" value="uymDS" /> <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource" /> <property name="xaProperties" ref="uymDbProperties" /> <property name="minPoolSize" value="10" /> <property name="maxPoolSize" value="20" /> <property name="borrowConnectionTimeout" value="30" /> <property name="testQuery" value="select 1" /> <property name="maintenanceInterval" value="60" /> </bean> <bean id="uymFileJdbcDao" class="com.xxx.domain.uym.UymFileJdbcDao"> <property name="dataSource" ref="uymDS" /> </bean>

The class follows the standard:

public class UymFileJdbcDao extends JdbcDaoSupport implements UymFileDao { }

Doing:
try { AtomikosDataSourceBean ds = (AtomikosDataSourceBean) getDataSource().getConnection(); } catch (SQLException e) { e.printStackTrace(); }

gives the bean - I make the changes and try
ds.close(); ds.init();

- log shows it initializing and I output the new url to make sure and the first insert for the UymFileJdbcDao inserts in the default url found in the uymdb.properties file.

I don't think my issue is the assigning of the url but how to force the AtomikosDataSourceBean to reset or the JtaTransactionManager to refresh?

I have looked at Spring AOP Hot Swappable Target Sources in my wanders but not sure.

Any pointers, again much appreciated.

Thanks,
Peter

Okay - I got the Datasource url database name not known until after a Batch step - fixed.

Here is what I have:

In my launch-context.xml (relevant parts)
<context:property-placeholder location="classpath:batch.properties,classpath:env-${envTarget}.properties" /> <bean id="udydb" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close" > <property name="driverClassName" value="${k12.jdbc.driver}" /> <property name="url" value="${client.udy.url}" /> <property name="username" value="${client.jdbc.user}" /> <property name="password" value="${client.jdbc.password}" /> </bean> <bean id="executionContextPromotionListener" class="org.springframework.batch.core.listener.ExecutionContextPromotionListener"> <property name="keys" value="importId" /> </bean> <bean id="TestBasicDataSource" class="com.k12knowledge.batch.TestBasicDataSource" > <property name="ds" ref="udydb" /> </bean>

The 'envTarget' is to allow the job to read different properties files e.g. development / production. I did have to put
a legitimate jdbc url string for the client.udy.url entry as otherwise I got sql errors. (As a precaution I have
created an empty dummy db so nothing returned on reads etc.)

My module-context.xml job section looks like:

<batch:job id="job1"> <batch:step id="verifyStep" next="setUdyDataSource"> <batch:tasklet ref="verifyTasklet"> <batch:listeners> <batch:listener ref="executionContextPromotionListener" /> </batch:listeners> </batch:tasklet> </batch:step> <batch:step id="setUdyDataSource" next="udytranStep"> <batch:tasklet ref="TestBasicDataSource" /> </batch:step> <batch:step id="udytranStep"> <batch:tasklet> <batch:chunk reader="udytranReader" writer="writer" commit-interval="100" /> </batch:tasklet> </batch:step> </batch:job>

VerifyStoreInStepContextTasklet (implements Tasklet) has:

public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception { ExecutionContext stepExecutionContext = chunkContext.getStepContext().getStepExecution().getExecutionContext(); stepExecutionContext.putString("importId", "ABC_14_2012"); // mimic file name retrieved return RepeatStatus.FINISHED; }

TestBasicDataSource (implements Tasklet) has:

public class TestBasicDataSource implements Tasklet { private BasicDataSource ds; public BasicDataSource getDs() { return ds; } public void setDs(BasicDataSource ds) { this.ds = ds; } public Logger getParentLogger() throws SQLFeatureNotSupportedException { // TODO Auto-generated method stub return null; } public <T> T unwrap(Class<T> iface) throws SQLException { // TODO Auto-generated method stub return null; } public boolean isWrapperFor(Class<?> iface) throws SQLException { // TODO Auto-generated method stub return false; } public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception { ExecutionContext jobExecutionContext = chunkContext.getStepContext().getStepExecution().getJobExecution().getExecutionContext(); String importId = jobExecutionContext.getString("importId"); ds.setUrl(ds.getUrl().substring(0, ds.getUrl().lastIndexOf("/") + 1) + importId); return RepeatStatus.FINISHED; } }

The next step in the job 'udytranStep' is my check to see what records are actually returned - it correctly connects to the batch job assigned db url and returns expected results.
Thanks to Mark for his help and hope this helps another newbie.

Hi Mark - thanks for the help / pointers.

I tried

<bean id="udydb" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="url" value="#{jobExecutionContext['importId']}" /> ... </bean>

and on run it is giving me:

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'udydb' defined in class path resource [launch-context.xml]: Initialization of bean failed; nested exception is org.springframework.beans.factory.BeanExpressionException: Expression parsing failed; nested exception is org.springframework.expression.spel.SpelEvaluationException: EL1008E:(pos 0): Field or property 'jobExecutionContext' cannot be found on object of type 'org.springframework.beans.factory.config.BeanExpressionContext'

so will keep reading / experimenting...

Per the transactionManager - if I am not using the transactional atm concept (i.e. money must be debited at the same time as withdrawn across different databases) but inserts / updates are single database specific I am thinking I can use the 1 transactionManager?
[Within a step might be an insert to a db on another machine but since that step will be tied to a jdbc writer and so its dataSource, commits / rollbacks should be handled by the 1 transactionManager, right?]

So far my ideas are half-baked! ;-)

Peter

Hello,

Been doing my reading (swirling around right now) and can't fix my current issue.

I have 5 datasources, three of which I can fill in 100% through a property file. The other 2 I have everything but the db name at the end of the url.

(An aside: am I correct in reading that I therefore need 5 Transaction Managers? - If so will follow up with a new question thread)

The schema is the same for db1 so no changes to rowmappers etc - just the db name (same principle for db2).

I came across Dynamic DataSource Routing which I worked through and got working as I try and understand how Spring does things.

I got 'USING THE STEP EXECUTION CONTEXT AND PROMOTING THE DATA TO THE JOB EXECUTION CONTEXT' (Chapter 10 Spring Batch in Action) working by creating the db name in
TrackImportFromJobContextTasklet and retrieving it in VerifyStoreInStepContextTasklet.

I tweaked VerifyStoreInStepContextTasklet to see if I could set the udydb datasource url.

public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception { ..... BeanFactory factory = new XmlBeanFactory(new ClassPathResource("launch-context.xml")); BasicDataSource bean1 = (BasicDataSource) factory.getBean("udydb"); bean1.setUrl(bean1.getUrl() + "ABC_14_2012"); System.out.println("url: " + bean1.getUrl());

In launch-context I have
<bean id="udydb" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="${client.jdbc.driver}" /> <property name="url" value="${client.udy.url}" /> <property name="username" value="${client.jdbc.user}" /> <property name="password" value="${client.jdbc.password}" /> </bean>

And the
System.out.println("url: " + bean1.getUrl());

gives

url: ${client.udy.url}ABC_14_2012

i.e. The datasource has not been instantiated yet (I think).

The next section in the book 'WRITING IN THE JOB EXECUTION CONTEXT AND READING USING LATE BINDING' won't work as in a different step.

So I am wrong in my thinking about the datasource and I think the code in VerifyStoreInStepContextTasklet breaches the whole separation of concerns?

I like the Dynamic Datasource Routing but can't figure out how to assign the db name which has been determined from an earlier step in the batch.

Any help appreciated. Thanks

Mark,

Thanks for the reply. (The storing of the file as a blob is for permanent record keeping.)

I'll get on with reading!

Hello,

I am a newbie to Spring and Spring Batch and don't know enough to know if the following is possible in Spring Batch.... We currently use Talend ETL for this but I am not 100% happy with it.

Database - mySQL. All linux machines.

Clients ftp flat files to multiple ftp servers. Every minute cron query checking scheduler table. On a 'hit' procedure triggered to check each ftp server client's directory for files and start processing. (Question: I could replace the scheduling with Quartz but looks like the cronExpression is set in a xml file so how to centrally manage and add new client processing scheduling params easily i.e. web interface?)

File picked up, backed up on file system and stored as a blob in database table determined by today's date and client Manufacturer (sending data for) abbreviation from scheduler table. e.g. ABC_2012_Nov. So a case of not knowing database until file is picked up. [For future scalability we look up an architecture schema table to determine on which machine this client's dbs are. (Currently all dbs are on one machine but the idea is that should a client's processing demands get too large we can setup another machine, move its dbs over and then update the architecture schema to new machine and away we go...)]

The FTP file processing procedure then, determines from architecture schema which machine to ssh to, does so and executes the next procedure - handing it the row id of logging table. This and subsequent procedures are now running on local client db machine.

Local Procedure looks up logging table row to get client details e.g. client number, file(s) names etc. Each file is then extracted from the ABC_2012_Nov table ready for conversion. To add to this we have instances where instead of one client per file we have a corporate file with multiple clients in the file. Currently this is handled by checking a db table to see if corporate type or not and then file parsed out to be client specific.

So at this point we know each file is client specific and db connection is set up per looped file e.g ABC_14_2012 (14 = client id). File row is converted into POJO and inserted (with duplicate data checks being done) into ABC_14_2012. Some queries to other db tables (table names are dynamic) are run to update/insert lookup row fields. [Though we have a fixed file layout schema not all clients adhere to it exactly. We have some (consistent per file) that are 314 in length, some 324 and some 329 in length. Another group use an edi like file layout - header, detail and footer section so Batch would need to know or determine which ItemReader schema(?) to use to create common to all, file layout POJO object representing file row.]

Next we do a count to see if we have any inserts that need validation and what type of validation e.g. public validation or private validation. If there are any of each - procedure now hands off to both or one etc.

Validation procedure looks up logging table to get client details e.g. which db to connect to and does so dynamically. Then for each row it processes it against the validation rules (examples of rules would be duplicates, invoice date test, quantity test, client test etc., some of which are connecting to another database and querying dynamically named client specific tables for these tests) and provided all pass - insert to other db tables.

Currently each procedure is segmented so that if one step fails - it can be re-run and following steps will then be called. This is why each looks up the logging table based on id given.

What I would like to see happen (if Spring Batch can do it) is:

Each ftp server act as Batch Master (for lack of a better word) that are both checking the same file processing scheduler. On hit each would backup the file(s) if any, inserting the file into the dynamically determined file db. Then hand off process to dynamically determined machine (idea of remote chunking?) while being kept updated via messaging on progress of node processing data (Batch Admin?) which could be seen via web interface.

Other thoughts: some of the db sql lookups ideally would be run in parallel.

As said don't know enough about Spring / Spring Batch to a) know if can be done b) not horrendously complicated forcing very steep learning curve. The 'Use Cases' on the Spring Batch website don't seem close enough to what I want and Spring Batch samples - don't know enough.

Any help / pointers appreciated. Thank you.

Thanks Ernest for explaining.

To complete the post:
I got it to work by replacing lockFile.exists() with true i.e. infinite loop and handling the start and stop via bourne scripts.

The start script puts the java program in the background and records the PID in the proftpd.lock file.
The stop script opens the proftpd.lock file and kills the PID recorded in it.

top monitoring tool is not showing the background java process being an issue so leaving as is....

Hello,

proFTPD can use a FIFO file as a log. The manual tells me I must start the monitoring fifo script before the proftpd is started. I found in the init.d script the start parameter and inserted:

proftpd start...
touch /opt/ftp/proftpd.lock
java Simple&

[Simple now in background]

Fifo reads:

public class Simple { public static void main(String args[]) { BufferedReader in = null; String lineRead = null; File fileName = new File("/opt/ftp/proftpd.fifo"); File lockFile = new File("/opt/ftp/proftpd.lock"); try { while(lockFile.exists()) { in = new BufferedReader(new FileReader(fileName)); lineRead = in.readLine(); if (lineRead != null) { if (lineRead.indexOf("QUIT") != -1) System.out.println(lineRead); // will be replaced with a call to a java program } } } catch (IOException e) { System.exit(0); } } }

In the init.d stop script I have:
rm /opt/ftp/proftpd.lock

which I thought would cause Simple to exit as lockFile no longer exists.

Any help - slaps to the side of the head appreciated.

Gregg - you are right of course.

For closure I would appreciate how to pass the gui reference in UrlConnect urlconn = new UrlConnect(); to the second class as I still draw a blank on how to to do this.

Thank you.

Thank you for the very quick reply.

I (understood) needed it as the xml returned in the second class has values that I want to populate certain textfield's text with. Is my thinking convoluted - is there a better way?

Also in the jFrame getJButtonVerify() where it says

UrlConnect urlconn = new UrlConnect();

what do I put between the ( and )? I have tried Gui thisClass, this without success.

Thank you

Hello,

I believe I need to instantiate a reference to the JFrame class in the UrlConnect Class - I do not how to do this. My current code gives me an NPE. I have tried to place the reference in the default constructor - no change. Creating a new instance - does not assign the values to the existing JFrame Gui. They are both in the same package. I really need a working example based on the code below. I have read posts and articles and am no clearer in what I need to do. I am using Eclipse VEP. Thank you. [The xml etc works without issue]

public class Gui extends JFrame { private static final long serialVersionUID = 1L; private JDesktopPane jDesktopPane = null; private JTextField jTextFieldCustNum = null; private JTextField jTextFieldOrderNum = null; private JLabel jLabelCustNum = null; private JLabel jLabelOrderNum = null; private JLabel jLabelInvDate = null; private JTextField jTextFieldInvDate = null; private JLabel jLabelProdNum = null; private JTextField jTextFieldProdNum = null; private JLabel jLabelCaseQty = null; private JTextField jTextFieldCaseQty = null; private JLabel jLabelCaseWt = null; private JTextField jTextFieldCaseWeight = null; private JButton jButtonVerify = null; private JTextArea jTextAreaOutput = null; private JScrollPane jScrollPane = null; private JMenuBar jJMenuBar = null; /** * This method initializes jDesktopPane * * @return javax.swing.JDesktopPane */ private JDesktopPane getJDesktopPane() { if (jDesktopPane == null) { jLabelCaseWt = new JLabel(); jLabelCaseWt.setText("Case Weight:"); jLabelCaseWt.setSize(new Dimension(152, 16)); jLabelCaseWt.setFont(new Font("Dialog", Font.BOLD, 14)); jLabelCaseWt.setLocation(new Point(43, 193)); jLabelCaseQty = new JLabel(); jLabelCaseQty.setText("Case Quantity:"); jLabelCaseQty.setLocation(new Point(43, 163)); jLabelCaseQty.setFont(new Font("Dialog", Font.BOLD, 14)); jLabelCaseQty.setSize(new Dimension(152, 16)); jLabelProdNum = new JLabel(); jLabelProdNum.setText("Product Number:"); jLabelProdNum.setSize(new Dimension(152, 16)); jLabelProdNum.setFont(new Font("Dialog", Font.BOLD, 14)); jLabelProdNum.setLocation(new Point(43, 134)); jLabelInvDate = new JLabel(); jLabelInvDate.setText("Invoice Date:"); jLabelInvDate.setSize(new Dimension(152, 16)); jLabelInvDate.setFont(new Font("Dialog", Font.BOLD, 14)); jLabelInvDate.setLocation(new Point(43, 103)); jLabelOrderNum = new JLabel(); jLabelOrderNum.setText("Order Number:"); jLabelOrderNum.setSize(new Dimension(152, 16)); jLabelOrderNum.setFont(new Font("Dialog", Font.BOLD, 14)); jLabelOrderNum.setLocation(new Point(43, 73)); jLabelCustNum = new JLabel(); jLabelCustNum.setBounds(new Rectangle(42, 43, 152, 16)); jLabelCustNum.setFont(new Font("Dialog", Font.BOLD, 14)); jLabelCustNum.setText("Customer Number:"); jDesktopPane = new JDesktopPane(); jDesktopPane.add(getJTextFieldCustNum(), null); jDesktopPane.add(getJTextFieldOrderNum(), null); jDesktopPane.add(jLabelCustNum, null); jDesktopPane.add(jLabelOrderNum, null); jDesktopPane.add(jLabelInvDate, null); jDesktopPane.add(getJTextFieldInvDate(), null); jDesktopPane.add(jLabelProdNum, null); jDesktopPane.add(getJTextFieldProdNum(), null); jDesktopPane.add(jLabelCaseQty, null); jDesktopPane.add(getJTextFieldCaseQty(), null); jDesktopPane.add(jLabelCaseWt, null); jDesktopPane.add(getJTextFieldCaseWeight(), null); jDesktopPane.add(getJButtonVerify(), null); jDesktopPane.add(getJScrollPane(), null); } return jDesktopPane; } /** * This method initializes jTextFieldCustNum * * @return javax.swing.JTextField */ private JTextField getJTextFieldCustNum() { if (jTextFieldCustNum == null) { jTextFieldCustNum = new JTextField(); jTextFieldCustNum.setBounds(new Rectangle(222, 42, 255, 20)); jTextFieldCustNum.setFont(new Font("Dialog", Font.PLAIN, 14)); } return jTextFieldCustNum; } /** * This method initializes jTextFieldOrderNum * * @return javax.swing.JTextField */ private JTextField getJTextFieldOrderNum() { if (jTextFieldOrderNum == null) { jTextFieldOrderNum = new JTextField(); jTextFieldOrderNum.setLocation(new Point(222, 73)); jTextFieldOrderNum.setFont(new Font("Dialog", Font.PLAIN, 14)); jTextFieldOrderNum.setSize(new Dimension(255, 20)); } return jTextFieldOrderNum; } /** * This method initializes jTextFieldInvDate * * @return javax.swing.JTextField */ private JTextField getJTextFieldInvDate() { if (jTextFieldInvDate == null) { jTextFieldInvDate = new JTextField(); jTextFieldInvDate.setSize(new Dimension(255, 20)); jTextFieldInvDate.setFont(new Font("Dialog", Font.PLAIN, 14)); jTextFieldInvDate.setLocation(new Point(222, 102)); } return jTextFieldInvDate; } /** * This method initializes jTextFieldProdNum * * @return javax.swing.JTextField */ private JTextField getJTextFieldProdNum() { if (jTextFieldProdNum == null) { jTextFieldProdNum = new JTextField(); jTextFieldProdNum.setSize(new Dimension(255, 20)); jTextFieldProdNum.setFont(new Font("Dialog", Font.PLAIN, 14)); jTextFieldProdNum.setLocation(new Point(222, 131)); } return jTextFieldProdNum; } /** * This method initializes jTextFieldCaseQty * * @return javax.swing.JTextField */ private JTextField getJTextFieldCaseQty() { if (jTextFieldCaseQty == null) { jTextFieldCaseQty = new JTextField(); jTextFieldCaseQty.setLocation(new Point(222, 162)); jTextFieldCaseQty.setFont(new Font("Dialog", Font.PLAIN, 14)); jTextFieldCaseQty.setSize(new Dimension(255, 20)); } return jTextFieldCaseQty; } /** * This method initializes jTextFieldCaseWeight * * @return javax.swing.JTextField */ private JTextField getJTextFieldCaseWeight() { if (jTextFieldCaseWeight == null) { jTextFieldCaseWeight = new JTextField(); jTextFieldCaseWeight.setLocation(new Point(222, 193)); jTextFieldCaseWeight.setFont(new Font("Dialog", Font.PLAIN, 14)); jTextFieldCaseWeight.setSize(new Dimension(255, 20)); } return jTextFieldCaseWeight; } /** * This method initializes jTextAreaOutput * * @return javax.swing.JTextArea */ private JTextArea getJTextAreaOutput() { if (jTextAreaOutput == null) { jTextAreaOutput = new JTextArea(); jTextAreaOutput.setEditable(false); } return jTextAreaOutput; } /** * This method initializes jScrollPane * * @return javax.swing.JScrollPane */ private JScrollPane getJScrollPane() { if (jScrollPane == null) { jScrollPane = new JScrollPane(jTextAreaOutput); jScrollPane.setBounds(new Rectangle(224, 223, 362, 110)); jScrollPane.setViewportView(getJTextAreaOutput()); } return jScrollPane; } /** * This method initializes jButtonVerify * * @return javax.swing.JButton */ private JButton getJButtonVerify() { if (jButtonVerify == null) { jButtonVerify = new JButton(); jButtonVerify.setBounds(new Rectangle(44, 239, 149, 26)); jButtonVerify.setText("Verify"); java.awt.event.ActionListener buttVerify = new java.awt.event.ActionListener() { public void actionPerformed(java.awt.event.ActionEvent e) { // prepare url string and send to UrlConnect String params[] = {jTextFieldCustNum.getText(), jTextFieldOrderNum.getText(), jTextFieldInvDate.getText(), jTextFieldProdNum.getText(), jTextFieldCaseQty.getText(), jTextFieldCaseWeight.getText()}; UrlConnect urlconn = new UrlConnect(); urlconn.UrlMain(params); } }; jButtonVerify.addActionListener(buttVerify); } return jButtonVerify; } /** * This method initializes jJMenuBar * * @return javax.swing.JMenuBar */ private JMenuBar getJJMenuBar() { if (jJMenuBar == null) { jJMenuBar = new JMenuBar(); JMenu menu = new JMenu("File"); menu.setMnemonic(KeyEvent.VK_F); java.awt.event.ActionListener al = new java.awt.event.ActionListener() { public void actionPerformed(java.awt.event.ActionEvent e) { System.out.println("action performed"); } }; /** The JMenuItem for exiting. */ JMenuItem exitItem; JMenuItem menuItem = new JMenuItem("Close", KeyEvent.VK_X); menuItem.setMnemonic(KeyEvent.VK_C); exitItem = menuItem; // save for action handler menuItem.addActionListener(al); menu.add(menuItem); jJMenuBar.add(menu); } return jJMenuBar; } // Setters & Getters public void setJTextFieldCustNumText(String textCustNum) { jTextFieldCustNum.setText(textCustNum); } public String getJTextFieldCustNumText() { return jTextFieldCustNum.getText(); } public void setJTextFieldOrderNum(JTextField textFieldOrderNum) { jTextFieldOrderNum = textFieldOrderNum; } public void setJTextFieldInvDate(JTextField textFieldInvDate) { jTextFieldInvDate = textFieldInvDate; } public void setJTextFieldProdNum(JTextField textFieldProdNum) { jTextFieldProdNum = textFieldProdNum; } public void setJTextFieldCaseQty(JTextField textFieldCaseQty) { jTextFieldCaseQty = textFieldCaseQty; } public void setJTextFieldCaseWeight(JTextField textFieldCaseWeight) { jTextFieldCaseWeight = textFieldCaseWeight; } public void setJTextAreaOutput(JTextArea textAreaOutput) { jTextAreaOutput = textAreaOutput; } /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub SwingUtilities.invokeLater(new Runnable() { public void run() { Gui thisClass = new Gui(); thisClass.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); thisClass.setVisible(true); } }); } /** * This is the default constructor */ public Gui() { super(); initialize(); } /** * This method initializes this * * @return void */ private void initialize() { this.setSize(624, 401); this.setJMenuBar(getJJMenuBar()); this.setContentPane(getJDesktopPane()); this.setTitle("K12 Product GUI"); } } // class Gui

Business Class
public class UrlConnect { Gui mainGui; public void UrlMain (String params[]) { try { URL url = new URL("http://www.notrealurl.com:80/test.php"); // Construct data String data = URLEncoder.encode("custnum", "UTF-8") + "=" + URLEncoder.encode(params[0], "UTF-8"); data += "&" + URLEncoder.encode("ordnum", "UTF-8") + "=" + URLEncoder.encode(params[1], "UTF-8"); data += "&" + URLEncoder.encode("invdate", "UTF-8") + "=" + URLEncoder.encode(params[2], "UTF-8"); data += "&" + URLEncoder.encode("prodnum", "UTF-8") + "=" + URLEncoder.encode(params[3], "UTF-8"); data += "&" + URLEncoder.encode("caseqty", "UTF-8") + "=" + URLEncoder.encode(params[4], "UTF-8"); data += "&" + URLEncoder.encode("casewt", "UTF-8") + "=" + URLEncoder.encode(params[5], "UTF-8"); System.out.println("data is: " + data); // send the url URLConnection conn = url.openConnection(); conn.setDoOutput(true); OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream()); wr.write(data); wr.flush(); wr.close(); // retrieve xml data XMLInputFactory inputFactory = XMLInputFactory.newInstance(); InputStream input = conn.getInputStream(); XMLStreamReader xmlStreamReader = inputFactory.createXMLStreamReader(input); // Process the xml stream XmlProcess(xmlStreamReader); } catch (MalformedURLException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (XMLStreamException e) { // TODO Auto-generated catch block e.printStackTrace(); } } // UrlMain public void XmlProcess(XMLStreamReader xmlreader) { try { while (xmlreader.hasNext()) { int event = xmlreader.next(); if (event == XMLStreamConstants.START_DOCUMENT) { System.out.println("Event Type:START_DOCUMENT"); } if (event == XMLStreamConstants.START_ELEMENT) { System.out.println("Event Type: START_ELEMENT"); System.out.println("Element Local Name:" + xmlreader.getLocalName()); if (xmlreader.getLocalName() == "custnum") { mainGui.setJTextFieldCustNumText(xmlreader.getLocalName()); // System.out.println("mainGui CustNum set: " + mainGui.getJTextFieldCustNumText()); } for (int i = 0; i < xmlreader.getAttributeCount(); i++) { System.out.println("Attribute Local Name:" + xmlreader.getAttributeLocalName(i)); System.out.println("Attribute Value:" + xmlreader.getAttributeValue(i)); } // for } // if if (event == XMLStreamConstants.CHARACTERS) { System.out.println("Event Type: CHARACTERS"); System.out.println("Text:" + xmlreader.getText()); } if (event == XMLStreamConstants.END_DOCUMENT) { System.out.println("Event Type:END_DOCUMENT"); } if (event == XMLStreamConstants.END_ELEMENT) { System.out.println("Event Type: END_ELEMENT"); } } // while } catch (XMLStreamException e) { // TODO Auto-generated catch block e.printStackTrace(); } } // XmlProcess }

Thanks for the correction Eric.

Now I remember why I didn't try this - got confused...

My updOrder code is

function updOrder (field1, field2){ var item = field1; var ordqty= field2; if (ordqty.value.length == 0) ordqty.value = 0; var url= "?orditm=" + encodeURIComponent(item) + "&ordqty=" + encodeURIComponent(ordqty.value); var ajax = new AJAXInteraction(url, validateCallback); ajax.doGet(); }

The validateCallback is

function validateCallback(responseXML) { var msg = responseXML.getElementsByTagName("valid")[0].firstChild.nodeValue; var lines = responseXML.getElementsByTagName("lines")[0].firstChild.nodeValue; var totpcs = responseXML.getElementsByTagName("pieces")[0].firstChild.nodeValue; var subtot = responseXML.getElementsByTagName("subtot")[0].firstChild.nodeValue; if (msg == "updated") { refreshTot(lines, totpcs, subtot); } } // validateCallback

If I understand correctly I should be putting the updExtend() inside the "msg == updated" statement. My question is what is the format for passing parameters into validateCallback?

updExtend() has three fields it requires.

Do I do something like this in the updOrder() function?
var ajax = new AJAXInteraction(url, validateCallback(field1, field2, field3);

and if so does my validateCallback look like this:

validateCallback(responseXML, field1, field2, field3) { var msg = responseXML.getElementsByTagName("valid")[0].firstChild.nodeValue; var lines = responseXML.getElementsByTagName("lines")[0].firstChild.nodeValue; var totpcs = responseXML.getElementsByTagName("pieces")[0].firstChild.nodeValue; var subtot = responseXML.getElementsByTagName("subtot")[0].firstChild.nodeValue; if (msg == "updated") { refreshTot(lines, totpcs, subtot); updExtend(field1, field2, field3); } } // validateCallback

Which does not seem to make sense to me...

Thanks,

Thanks Gregg.

I will try that as I would like to see it work in Firefox so I can offer both options to end users.