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

您所在的位置：网站首页 › java连接gp数据库 › java JDBC连接数据库步骤及代码

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

2023-12-13 15:28| 来源: 网络整理| 查看: 265

JDBC连接数据库，包含7个步骤

（1）加载JDBC驱动程序

在连接数据库之前，首先要加载想要连接的数据库的驱动到JVM（Java虚拟机），这通过java.lang.Class类的静态方法forName(String className)实现，成功加载后，会将Driver类的实例注册到DriverManager类中。

代码如下：

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

表示感谢！！

【本文地址】

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

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

今日新闻

推荐新闻