jdbcprofileprovider4exp.java

这个是使用java开发的一个平台

/*
 * Created on 2005-8-4
 * 
 * TODO To change the template for this generated file go to Window -
 * Preferences - Java - Code Style - Code Templates
 */
package com.exp.integration.osworkflow.user;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.List;
import java.util.Properties;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.exp.dao.DBConnectionFactory;
import com.exp.integration.osworkflow.OSWorkFlowDBConfigUtil;
import com.opensymphony.module.propertyset.PropertySet;
import com.opensymphony.module.propertyset.PropertySetManager;
import com.opensymphony.user.provider.ProfileProvider;
import com.opensymphony.user.provider.jdbc.BaseJDBCProvider;

// Referenced classes of package com.opensymphony.user.provider.jdbc:
//            BaseJDBCProvider

public class JDBCProfileProvider4EXP extends BaseJDBCProvider implements
        ProfileProvider {

    private static final Log log;

    protected String dataSource = "";

    public Connection getConnection() {
        try {
            return DBConnectionFactory.createDBConnection(this.dataSource)
                    .getConnection();
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    public PropertySet getPropertySet(String name) {
        HashMap args = new HashMap();
        args.put("globalKey", "OSUser_" + name);
        return PropertySetManager.getInstance("jdbc", args);
    }

    public boolean handles(String name) {
        boolean handles = false;
        Connection conn = getConnection();
        try {
            PreparedStatement ps = conn.prepareStatement("SELECT * FROM "
                    + userTable + " WHERE " + userName + " = ?");
            ps.setString(1, name);
            ResultSet rs = ps.executeQuery();
            handles = rs.next();
            rs.close();
            ps.close();
        } catch (SQLException e) {
            log.fatal("Could not see if [" + name + "] is handled", e);
        } finally {
                try {
                    conn.close();
                } catch (Exception e) {

                }
        }
        return handles;
    }

    public List list() {
        return null;
    }

    /*
     * (non-Javadoc)
     * 
     * @see com.opensymphony.user.provider.UserProvider#init(java.util.Properties)
     */
    public boolean init(Properties dual) {
        Properties props = OSWorkFlowDBConfigUtil.getOsuserProps();
        ;
        dataSource = props.getProperty("datasource");
        if (dataSource == null) {
            dataSource = "";
        }
        userTable = (String) props.get("user.table");
        groupTable = (String) props.get("group.table");
        membershipTable = (String) props.get("membership.table");
        userName = (String) props.get("user.name");
        userPassword = (String) props.get("user.password");
        groupName = (String) props.get("group.name");
        membershipUserName = (String) props.get("membership.userName");
        membershipGroupName = (String) props.get("membership.groupName");
        return true;
    }

    static {
        log = LogFactory
                .getLog("com.opensymphony.user.provider.jdbc.JDBCProfileProvider");
    }
}