package com.bluedot.bank.framework.sql;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

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

public class MySqlInfo {
	private static DataSource dataSource;
	public Connection getConnection() {
		Connection connection;
		
		try {
			if(dataSource==null){
				Context context = new InitialContext();
				dataSource=(DataSource) context.lookup("java:/comp/env/jdbc/mysql");
			}
			connection =dataSource.getConnection();
			connection.setAutoCommit(false);
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
		return connection;
	}
//	public Connection getConnection() {
//		Connection connection;
//		try {
//			
//			Class.forName("org.gjt.mm.mysql.Driver");
//			connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8", "root", "www");
//			connection.setAutoCommit(false);
//		} catch (Exception e) {
//			throw new RuntimeException(e);
//		}
//		return connection;
//	}
	
	public void closeCon(Connection connection){
		
		try {
			if(connection!=null){
				connection.close();
			}
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}
	}
	
	public void  rollback(Connection connection) {
		try {
			connection.rollback();
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}
	}

}