2025年java JDBC连接数据库步骤及代码

代码如下：

static{
	try {
		Class.forName("com.mysql.jdbc.Driver");//加载数据库驱动
		}
	catch (ClassNotFoundException e) {
		e.printStackTrace();
	}
}

（2）提供JDBC连接的URL

书写形式：协议：子协议：数据源标识。其中：

协议：在JDBC中总是以jdbc开始。子协议：是桥连接的驱动程序或是数据库管理系统名称。数据源标识：标记找到数据库来源的地址与连接端口。

代码如下：

//连接MySql数据库，用户名和密码都是root   

     String url = "jdbc:mysql://localhost:3306/test" ;    

     String username = "root" ;   

     String password = "root" ;

（3）创建数据库的连接

代码如下：

 public static Connection getConn(){

    	 Connection conn = null;

    	 try {

    		conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root","root");//连接数据库	

    		 }

         catch(SQLException e){

    		 e.printStackTrace();

    	 }

    	 return conn;

 }

（4）创建一个Statement

要执行SQL语句，必须获得java.sql.Statement实例，Statement实例分为以下3 种类型：

执行静态SQL语句。通常通过Statement实例实现。

执行动态SQL语句。通常通过PreparedStatement实例实现。

执行数据库存储过程。通常通过CallableStatement实例实现。

代码如下：

 public static Statement getStmt(Connection conn){
   Statement stmt = null;
   try {
	stmt = conn.createStatement();
} catch (SQLException e) {
	e.printStackTrace();
}
   return stmt;

   }

（5）执行SQL语句

Statement接口提供了三种执行SQL语句的方法：executeQuery 、executeUpdate 和execute

ResultSet executeQuery(String sqlString)：执行查询数据库的SQL语句，返回一个结果集（ResultSet）对象。

int executeUpdate(String sqlString)：用于执行INSERT、UPDATE或 DELETE语句以及SQL DDL语句，如：CREATE TABLE和DROP TABLE等

execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的语句。

代码如下：

 public static ResultSet executeQuery(Statement stmt,String sql){
 ResultSet rs = null;
 try {
	rs = stmt.executeQuery(sql);
} catch (SQLException e) {
	e.printStackTrace();
}
return rs; 

 }

（6）处理结果

两种情况：

执行更新返回的是本次操作影响到的记录数。

执行查询返回的结果是一个ResultSet对象。

ResultSet包含符合SQL语句中条件的所有行，并且它通过一套get方法提供了对这些行中数据的访问。

使用结果集（ResultSet）对象的访问方法获取数据，代码如下：

while(rs.next()){             

    String name = rs.getString("name") ;        

    String pass = rs.getString(1) ; // 此方法比较高效         

}

（7）关闭JDBC对象

操作完成以后要把所有使用的JDBC对象全都关闭，以释放JDBC资源，关闭顺序和声明顺序相反：

关闭记录集

关闭声明

关闭连接对象

代码如下：

//关闭结果集

 public static void closeRs(ResultSet rs){
   try {
		if(rs != null ){
			 rs.close();
			 rs = null;
		   }
	} catch (SQLException e) {
		e.printStackTrace();
	} 

 }

//关闭执行方法

 public static void closeStmt(Statement stmt){
   try {
		if(stmt != null ){
			 stmt.close();
			 stmt = null;
		   }
	} catch (SQLException e) {
		e.printStackTrace();
	} 
   

   }

//关闭连接

 public static void closeConn(Connection conn){
   try {
	if(conn != null ){
		 conn.close();
		 conn = null;
	   }
} catch (SQLException e) {
	e.printStackTrace();
}

 }

JDBC连接数据库工具类代码

package com.njau.allnetitem;



import java.sql.*;



public class DB {
static{
	try {
		Class.forName("com.mysql.jdbc.Driver");//加载数据库驱动
		}
	catch (ClassNotFoundException e) {
		e.printStackTrace();
	}
}


 private DB() {}

 

 public static Connection getConn(){

    	 Connection conn = null;

    	 try {

    		conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db_baima", "root","123456");//连接数据库	

    		 }

         catch(SQLException e){

    		 e.printStackTrace();

    	 }

    	 return conn;

 }

 

 public static void closeConn(Connection conn){
   try {
	if(conn != null ){
		 conn.close();
		 conn = null;
	   }
} catch (SQLException e) {
	e.printStackTrace();
}

 }

   

 public static Statement getStmt(Connection conn){
   Statement stmt = null;
   try {
	stmt = conn.createStatement();
} catch (SQLException e) {
	e.printStackTrace();
}
   return stmt;

   }

   

 public static PreparedStatement getPStmt(Connection conn,String sql){
   PreparedStatement pstmt = null;
   try {
	pstmt = conn.prepareStatement(sql);
} catch (SQLException e) {
	e.printStackTrace();
}
   return pstmt;

   }

   

 public static void closeStmt(Statement stmt){
   try {
		if(stmt != null ){
			 stmt.close();
			 stmt = null;
		   }
	} catch (SQLException e) {
		e.printStackTrace();
	} 
   

   }

   

 public static ResultSet executeQuery(Statement stmt,String sql){
 ResultSet rs = null;
 try {
	rs = stmt.executeQuery(sql);
} catch (SQLException e) {
	e.printStackTrace();
}
return rs; 

 }

 

 public static void closeRs(ResultSet rs){
   try {
		if(rs != null ){
			 rs.close();
			 rs = null;
		   }
	} catch (SQLException e) {
		e.printStackTrace();
	} 

 } 

 

 public static ResultSet executeQuery(Connection conn,String sql){//重载
 ResultSet rs = null;
 try {
	rs = conn.createStatement().executeQuery(sql);
} catch (SQLException e) {
	e.printStackTrace();
}
return rs;  

   } 

 }

工具类使用说明代码

//插入数据

public static void saveinfo(Object[] data) throws ParseException{
Connection conn = null;
PreparedStatement pstmt = null;

try {

    conn= DB.getConn();
String sql = "insert into information value (null,?,?,?,?,?,?,?) ";

    pstmt = DB.getPStmt(conn, sql);
pstmt.setString(1,(String) data[0]);
pstmt.setString(2, (String) data[1]);
pstmt.setString(3,(String) data[2]);
pstmt.setString(4,(String) data[3]); 
pstmt.setString(5,(String) data[4]);
pstmt.setString(6,(String) data[5]);
pstmt.setTimestamp(7 ,(Timestamp)data[6]);
pstmt.executeUpdate();
} 
catch (SQLException e) {
	e.printStackTrace();
}

    finally{

    	DB.closeStmt(pstmt);

    	DB.closeConn(conn);

    }

}

参考：

http://www.cnblogs.com/hongten/archive/2011/03/29/1998311.html

表示感谢！！

2025年java JDBC连接数据库步骤及代码

相关推荐