getconnection.java

Java开发的权限管理的例子

package com.datasource;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;

import com.gsta.eshore.framework.dao.DBConnectionManager;
import com.gsta.eshore.framework.exeception.ClientException;
import com.gsta.eshore.framework.util.uid.UID;

public class GetConnection {
	private static DataSource ds=getDataSource("java:/mysqlforJCFDS");
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		GetConnection db=new GetConnection();
//		Connection con=db.getConnection("java:/mysqlforJCFDS");
//		System.out.println(db.getConnection("java:/mysqlforJCFDS"));
//		for(int i=0;i<400;i++){
//			db.select(con);
//		}
		db.insertuser();
		db.insertuserinfo();
	}
	
	public void select(Connection con){
		ResultSet rs=null;
		PreparedStatement statement=null;
		try {
			statement = con.prepareStatement("select * from t_user");
			rs=statement.executeQuery();
			while(rs.next()){
				System.out.println(rs.getString(1));
				System.out.println(rs.getString(2));
				System.out.println(rs.getString(3));
			}

		} catch (SQLException e) {
			e.printStackTrace();
			try {
				con.rollback();
			} catch (SQLException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
		}finally{
			try {
				rs.close();
				statement.close();
				con.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
	}
	
	public void insertuser(){
		Connection con=null;
		ResultSet rs=null;
		PreparedStatement statement=null;
		try {
			con=ds.getConnection();
			statement = con.prepareStatement("insert into t_user values('"+UID.getUID()+"','oo','pp',1,'notetest')");
			int i=statement.executeUpdate();
		    System.out.println("i = "+i);

		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			try {
				con.rollback();
			} catch (SQLException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
		}finally{
			try {
				statement.close();
				con.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
	}
	
	
	public void insertuserinfo(){
		Connection con=null;
		ResultSet rs=null;
		PreparedStatement statement=null;
		try {
			con=ds.getConnection();
			statement = con.prepareStatement("insert into t_user_info(id,user_name,nick_name) values('"+UID.getUID()+"','hewq','google')");
			int i=statement.executeUpdate();
		    System.out.println("i = "+i);
		   // throw new ClientException("error happend","");
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			try {
				con.rollback();
			} catch (SQLException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
		}finally{
			try {
				statement.close();
				con.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
	}
	
	 public static DataSource getDataSource(String dsName) {
	        DataSource ds = null;
	        Connection conn = null;

	        try {

				 Properties prop = System.getProperties();
				 prop.put("java.naming.factory.initial","org.jnp.interfaces.NamingContextFactory");
				 prop.put("java.naming.factory.url.pkgs","org.jboss.naming:org.jnp.interfaces");
				 prop.put("java.naming.provider.url", "localhost:1099");
				 
	            Context ctx = new InitialContext(prop);
	            //tomcat
				ds = (DataSource) ctx.lookup(dsName);
	            //ds = (DataSource) ctx.lookup("java:comp/env/hw");
	            // jboss ds = (DataSource) ctx.lookup("java:/hw");

	            //logger.info("GET sql Connection scuess : conn = " + conn);
	            return ds;
	        }
	        catch (Exception ex) {
	            System.out.println(ex.getMessage());
	            //logger.error("get sql Connection failure : " + ex.getMessage());
	        }
	        return null;
	    }

}