connectioncfg.java

野蔷薇论坛源码 java 自己看看吧。 学习用

/* 
 * Created on 2007-05-31
 * Last modified on 2007-05-31
 * Powered by GamVan.com
 */
package com.yeqiangwei.club.passport.conn;

import java.io.InputStream;

import org.apache.log4j.Logger;

import com.yeqiangwei.util.XmlOperate;


public class ConnectionCfg {
	
	private static final Logger logger = Logger.getLogger(ConnectionCfg.class);
	
	public static void main(String args[]){
		String s =  null;
		System.out.println(s);
	}

	private static XmlOperate XML;
	
	public static Config CONFIG;
	
	public static String SQL_CREATE;
	
	public static String SQL_UPDATE_USERNAME;
	
	public static String SQL_FIND_USERID;
	
	public static String SQL_LOGIN;
	
	public static String SQL_FIND_USERNAME;
	
	public static String SQL_FIND_EMAIL;
	
	static{
		if(XML==null){
			logger.error("read config XML");
			InputStream stream = ConnectionCfg.class.getResourceAsStream("/passport.cfg.xml");
			if(stream==null){
				stream 
					= Thread.currentThread().getContextClassLoader().getResourceAsStream("/passport.cfg.xml");
				if(stream==null){
					logger.error("无法获取配置文件!");
				}
			}
			XML = new XmlOperate(stream);
		}
		if(CONFIG==null){
			CONFIG = ConnectionCfg.getInstance();
		}
		SQL_CREATE = createSQL();
		SQL_UPDATE_USERNAME = updateSQL();
		SQL_FIND_USERNAME = findByUserNameSQL();
		SQL_FIND_USERID = findByUserIdSQL();
		SQL_FIND_EMAIL =findByEmailSQL();
		SQL_LOGIN = loginSQL();
		logger.info("初始化 SQL_CREATE "+SQL_CREATE);
		logger.info("初始化 SQL_UPDATE "+SQL_UPDATE_USERNAME);
		logger.info("初始化 SQL_FIND_USERID "+SQL_FIND_USERID);
		logger.info("初始化 SQL_FIND_USERNAME "+SQL_FIND_USERNAME);
		logger.info("初始化 SQL_FIND_EMAIL "+SQL_FIND_EMAIL);
		logger.info("初始化 SQL_LOGIN "+SQL_LOGIN);
	}

	public static String loginSQL(){
		StringBuffer sql = new StringBuffer();
		sql.append("select * from ");
		sql.append(CONFIG.getTableName());
		sql.append(" where ");
		sql.append(CONFIG.getUserName());
		sql.append("=? and ");
		sql.append(CONFIG.getPassword());
		sql.append("=?");
		return sql.toString();
	}
	
	public static String findByUserNameSQL(){
		StringBuffer sql = new StringBuffer();
		sql.append("select * from ");
		sql.append(CONFIG.getTableName());
		sql.append(" where ");
		sql.append(CONFIG.getUserName());
		sql.append("=?");
		return sql.toString();
	}
	
	public static String findByUserIdSQL(){
		StringBuffer sql = new StringBuffer();
		sql.append("select * from ");
		sql.append(CONFIG.getTableName());
		sql.append(" where ");
		sql.append(CONFIG.getUserId());
		sql.append("=?");
		return sql.toString();
	}
	
	public static String findByEmailSQL(){
		StringBuffer sql = new StringBuffer();
		sql.append("select * from ");
		sql.append(CONFIG.getTableName());
		sql.append(" where ");
		sql.append(CONFIG.getEmail());
		sql.append("=?");
		return sql.toString();
	}
	
	public static String updateSQL(){
		StringBuffer sql = new StringBuffer();
		sql.append("update ");
		sql.append(CONFIG.getTableName());
		sql.append(" set ");
		sql.append(CONFIG.getUserName());
		sql.append("=?, ");
		sql.append(CONFIG.getPassword());
		sql.append("=?, ");
		sql.append(CONFIG.getEmail());
		sql.append("=?, ");
		sql.append(CONFIG.getSex());
		sql.append("=? where ");
		sql.append(CONFIG.getUserName());
		sql.append("=?");
		return sql.toString();
	}
	
	public static String createSQL(){
		StringBuffer sql = new StringBuffer();
		sql.append("insert into ");
		sql.append(CONFIG.getTableName());
		sql.append("(");
		sql.append(CONFIG.getUserName());
		sql.append(",");
		sql.append(CONFIG.getPassword());
		sql.append(",");
		sql.append(CONFIG.getEmail());
		sql.append(",");
		sql.append(CONFIG.getSex());
		sql.append(") values(?,?,?,?)  select @@Identity as ");
		sql.append(CONFIG.getUserId());
		return sql.toString();
	}
	
	
	public static String getChildText(String ele, String s){
		return XML.getChildText(XML.getElement(ele),s);
	}
	
	public static synchronized Config getInstance(){
		Config config = new Config();
		config.setConn_datasource(getChildText("connection-passport","conn_datasource"));
		config.setConn_username(getChildText("connection-passport","conn_username"));
		config.setConn_password(getChildText("connection-passport","conn_password"));
		config.setConn_url(getChildText("connection-passport","conn_url"));

		config.setTableName(getChildText("connection-passport","tableName"));
		config.setUserId(getChildText("connection-passport","userId"));
		config.setUserName(getChildText("connection-passport","userName"));
		config.setPassword(getChildText("connection-passport","password"));
		config.setSex(getChildText("connection-passport","sex"));
		config.setEmail(getChildText("connection-passport","email"));
		return config;
	}

}