Java 连接 mysql 数据库

package com.prodoc.struts.data;

 

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

public class Dataconn {
 
 private String sDBDriver = "com.mysql.jdbc.Driver";
 private String sConnStr = "jdbc:mysql://localhost:3306/bgpintl";
 private String username = "root";
 private String password = "comtowerbgpserverDataconn";
 private Connection conn = null;
 private Statement stmt = null;
 private ResultSet rs = null;
 
 
 public Connection getConnection() {
  try {
   Class.forName(sDBDriver);
   conn = DriverManager.getConnection(sConnStr, username, password);
//      Context initCtx;
//   Context ctx;
//   Object obj;
//   try {
//    initCtx = new InitialContext();
//    ctx = (Context) initCtx.lookup("java:comp/env");
//    obj = (Object) ctx.lookup("jdbc/GwtSample");
//    javax.sql.DataSource ds = (javax.sql.DataSource) obj;
//    conn = ds.getConnection();
//   } catch (NamingException e) {
//    // TODO Auto-generated catch block
//    e.printStackTrace();
//   } catch (SQLException e) {
//    // TODO Auto-generated catch block
//    e.printStackTrace();
//   }

  } catch (Exception e) {
   System.out.println("DBConnect():" + e.getMessage());
  }
  return conn;
 }

 //执行sql语句，用以查询

 public ResultSet executeQuery(String sql) {
  try {
      stmt = conn.createStatement();
   rs = stmt.executeQuery(sql);
  } catch (SQLException ex) {
   System.out.println("sql.executeQuery:" + ex.getMessage());
  }
  return rs;
 }
 
 //执行sql语句，用以更新

 public int executeUpdate (String sql) {
  int rs=0;
  try {
      stmt = conn.createStatement();
      rs = stmt.executeUpdate(sql);
  } catch (SQLException ex) {
   System.out.println("sql.executeQuery:" + ex.getMessage());
  }
  return rs;
 }
 
 
 public void closeConn() {
  
  if (rs != null) {
   try {
    rs.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
  
  if (stmt != null) {
   try {
    stmt.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
  if (conn != null) {
   try {
    conn.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
 }
}