JdbcRa.java

package org.objectweb.jonas.ant.jonasbase;

import java.io.File;
import java.util.Date;
import java.util.Properties;

import org.apache.tools.ant.BuildException;
import org.apache.tools.ant.taskdefs.Java;

import org.objectweb.jonas.ant.JOnASBaseTask;

public class JdbcRa extends JTask implements BaseTaskItf {

    private static final String INFO = "[JdbcRa] ";

    private static final String JONAS_JDBCDM = "JOnAS_jdbcDM";

    private static final String RACONFIG_CLASS = "org.objectweb.jonas_rar.raconfig.RAConfig";

    private static final String P6SPY_DRIVER = "com.p6spy.engine.spy.P6SpyDriver";

    private static final String REALDRIVER_PROPERTY = "realdriver";

    private String name = null;

    private String mapperName = null;

    private String user = null;

    private String password = null;

    private String url = null;

    private String driverName = null;

    private String realDriverName = null;

    private String jndiName = null;

    private boolean autoload = true;

    private boolean p6spy = false;

    public void setName(String name) {
        this.name = name;
    }

    public void setMapperName(String mapperName) {
        this.mapperName = mapperName;
    }

    public void setUser(String user) {
        this.user = user;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public void setUrl(String url) {
        this.url = url;
    }

    public void setDriverName(String driverName) {
        this.driverName = driverName;
        this.realDriverName = driverName;
    }

    public void setJndiName(String jndiName) {
        this.jndiName = jndiName;
    }

    private void checkProperties() {
        if (name == null) {
            throw new BuildException(INFO + "Property 'name' is missing.");
        } else if (mapperName == null) {
            throw new BuildException(INFO + "Property 'mapperName' is missing.");
        } else if (user == null) {
            throw new BuildException(INFO + "Property 'user' is missing.");
        } else if (password == null) {
            throw new BuildException(INFO + "Property 'password' is missing.");
        } else if (url == null) {
            throw new BuildException(INFO + "Property 'url' is missing.");
        } else if (driverName == null) {
            throw new BuildException(INFO + "Property 'driverName' is missing.");
        } else if (jndiName == null) {
            throw new BuildException(INFO + "Property 'jndiName' is missing.");
        }
    }

    private Properties getProperties() {
        // Check properties
        checkProperties();

        Properties props = new Properties();
        props.put("datasource.name", jndiName);
        props.put("datasource.url", url);
        if (p6spy) {
            driverName = P6SPY_DRIVER;
        }
        props.put("datasource.classname", driverName);
        props.put("datasource.username", user);
        props.put("datasource.password", password);
        props.put("datasource.mapper", mapperName);
        return props;
    }

    public void execute() {

        // Build new temp file for making a resource adaptor
        File tmpFile = new File(System.getProperty("java.io.tmpdir"), String.valueOf(new Date().getTime()));

        // Write properties to a file
        Properties props = getProperties();
        writePropsToFile(INFO, props, tmpFile);

        // Build resource adapter for this configuration

        // args
        String jRootRarsDir = getJonasRoot().getPath() + File.separator + "rars" + File.separator + "autoload";
        String jBaseRarsDir = getDestDir().getPath() + File.separator + "rars";
        if (isAutoload()) {
            jBaseRarsDir += File.separator + "autoload";
        }
        String jdbcDM = jRootRarsDir + File.separator + JONAS_JDBCDM;
        String destRarFile = jBaseRarsDir + File.separator + name + ".rar";

        Java raConfigTask = getBootstraptask("");
        raConfigTask.clearArgs();
        raConfigTask.createArg().setValue(RACONFIG_CLASS);
        raConfigTask.createArg().setValue("-dm");
        raConfigTask.createArg().setValue("-p");
        raConfigTask.createArg().setValue(tmpFile.getPath());
        raConfigTask.createArg().setValue(jdbcDM);
        raConfigTask.createArg().setValue(destRarFile);

        log(INFO + "Generating a rar file with name '" + name + "', mapperName '" + mapperName + "', user '" + user
                + "', password '" + password + "', URL '" + url + "', driverName '" + driverName + "' and jndiName '"
                + jndiName + "'...");

        try {
            raConfigTask.execute();
        } catch (Exception rae) {
            rae.printStackTrace();
            throw new BuildException(INFO + "Cannot make a resource adaptor on RAConfig: " + rae.getMessage());
        } finally {
            tmpFile.delete();
        }
        log(INFO + "Rar generated : '" + destRarFile + "'.");

        // P6Spy tool Configuration
        if (p6spy) {
            // Set the realdriver property of the JONAS_BASE/conf/spy.properties P6Spy configuration file
            String jBaseConf = getJonasRoot().getPath() + File.separator + "conf";
            changeValueForKey(INFO, jBaseConf, JOnASBaseTask.P6SPY_CONF_FILE,
                    REALDRIVER_PROPERTY, realDriverName, "=", false);
        }
    }

    public boolean isAutoload() {
        return autoload;
    }

    public void setAutoload(boolean autoload) {
        this.autoload = autoload;
    }

    public boolean isP6spy() {
        return p6spy;
    }

    public void setP6spy(boolean p6spy) {
        this.p6spy = p6spy;
    }
}

---