AbsDBServiceImpl.java

package org.objectweb.jonas.db;

import java.util.ArrayList;
import java.util.List;
import java.util.StringTokenizer;

import javax.naming.Context;
import javax.naming.NamingException;

import org.objectweb.jonas.common.Log;
import org.objectweb.jonas.service.AbsServiceImpl;
import org.objectweb.jonas.service.ServiceException;
import org.objectweb.util.monolog.api.BasicLevel;
import org.objectweb.util.monolog.api.Logger;

public abstract class AbsDBServiceImpl extends AbsServiceImpl {

    private static final String PORT_NUMBER = "jonas.service.db.port";

    private static final String DATABASE_NAME = "jonas.service.db.dbname";

    private static final String DEFAULT_DATABASE_NAME = "db_jonas";

    private static final String USERS = "jonas.service.db.user";

    private static Logger logger = null;

    protected void doInit(Context ctx) throws ServiceException {
        logger = Log.getLogger(Log.JONAS_DB_PREFIX);

        // Lookup port number
        String port = null;
        try {
            port = (String) ctx.lookup(PORT_NUMBER);
        } catch (NamingException ne) {
            logger.log(BasicLevel.INFO, "Use the default port as the property is missing in jonas.properties file");
        }

        // Database name
        String databaseName = null;
        try {
            databaseName = (String) ctx.lookup(DATABASE_NAME);
        } catch (NamingException ne) {
            logger.log(BasicLevel.INFO, "Use the default databsename '" + DEFAULT_DATABASE_NAME
                    + "' as the property is missing in jonas.properties file.");
            databaseName = DEFAULT_DATABASE_NAME;
        }

        // Users
        List users = new ArrayList();
        boolean hasUsers = true;
        int i = 1;
        while (hasUsers) {
            try {
                String usernameAndPass = (String) ctx.lookup(USERS + i);
                logger.log(BasicLevel.DEBUG, "Adding user/password '" + usernameAndPass + "'.");

                StringTokenizer st = new StringTokenizer(usernameAndPass, ":");
                String name = st.nextToken();
                String pass = "";
                if (st.hasMoreTokens()) {
                    pass = st.nextToken();
                }
                users.add(new User(name, pass));
            } catch (NamingException ne) {
                logger.log(BasicLevel.DEBUG, "No more users (length =" + i + ").");
                hasUsers = false;
            }
            i++;
        }

        initServer(users, databaseName, port);
    }

    protected abstract void initServer(List users, String databaseName, String portNumber);

    protected void doStart() throws ServiceException {
        logger.log(BasicLevel.DEBUG, "");
    }

    protected void doStop() throws ServiceException {
        logger.log(BasicLevel.DEBUG, "");
    }

    public static Logger getLogger() {
        return logger;
    }
}

---