电子发烧友App
创建一个以JDBC连接数据库的程序，包含7个步骤：
1、加载JDBC驱动程序：
在连接数据库之前，首先要加载想要连接的数据库的驱动到JVM（Java虚拟机）， 这通过java.lang.Class类的静态方法forName（String className）实现。
例如：
try{
//加载MySql的驱动类
Class.forName（“com.mysql.jdbc.Driver”） ;
}catch（ClassNotFoundException e）{
System.out.println（“找不到驱动程序类 ，加载驱动失败！”）;
e.printStackTrace（） ;
}
成功加载后，会将Driver类的实例注册到DriverManager类中。
不同数据库厂商的驱动类名不同
Oracle10g：oracle.jdbc.driver.OracleDriver
MySQL5：com.mysql.jdbc.Driver
SQLServer2005：com.microsoft.sqlserver.jdbc.SQLServerDriver
2、提供JDBC连接的URL
•连接URL定义了连接数据库时的协议、子协议、数据源标识。
•书写形式：协议：子协议：数据源标识
协议：在JDBC中总是以jdbc开始
子协议：是桥连接的驱动程序或是数据库管理系统名称。
数据源标识：标记找到数据库来源的地址与连接端口。
例如：（MySql的连接URL）
jdbc:mysql://localhost:3306/test？ ;
不同数据库产品的连接URL不同
Oracle10g：jdbc:oracle:thin：@主机名：端口：数据库SID
jdbc:oracle:thin：@localhost:1521:ORCL
MySQL5：jdbc:mysql://主机名：端口/数据库名
jdbc:mysql://localhost:3306/test
SQLServer2005：jdbc:sqlserver://主机名：端口：DatabaseName=库名
jdbc:sqlserver://localhost:1433:DatabaseName=BookDB
数据库的用户名和密码
3、创建数据库的连接
•要连接数据库，需要向java.sql.DriverManager请求并获得Connection对象，该对象就代表一个数据库的连接。
•使用DriverManager的getConnectin（String url ， String username ， String password ）方法传入指定的欲连接的数据库的路径、数据库的用户名和 密码来获得。
例如：
//连接MySql数据库，用户名和密码都是root
String url = “jdbc:mysql://localhost:3306/test” ;
String username = “root” ;
String password = “root” ;
try{
Connection con =
DriverManager.getConnection（url ， username ， password ） ;
}catch（SQLException se）{
System.out.println（“数据库连接失败！”）;
se.printStackTrace（） ;
}
4、创建一个Statement
•要执行SQL语句，必须获得java.sql.Statement实例，Statement实例分为以下3 种类型：
1、执行静态SQL语句。通常通过Statement实例实现。
2、执行动态SQL语句。通常通过PreparedStatement实例实现。
3、执行数据库存储过程。通常通过CallableStatement实例实现。
具体的实现方式：
Statement stmt = con.createStatement（） ;
PreparedStatement pstmt = con.prepareStatement（sql） ;
CallableStatement cstmt =
con.prepareCall（“{CALL demoSp（？ ， ？）}”） ;
5、执行SQL语句
Statement接口提供了三种执行SQL语句的方法：executeQuery 、executeUpdate 和execute
1、ResultSet executeQuery（String sqlString）：执行查询数据库的SQL语句，返回一个结果集（ResultSet）对象。
2、int executeUpdate（String sqlString）：用于执行INSERT、UPDATE或 DELETE语句以及SQL DDL语句，如：CREATE TABLE和DROP TABLE等
3、execute（sqlString）：用于执行返回多个结果集、多个更新计数或二者组合的语句。
具体实现的代码：
ResultSet rs = stmt.executeQuery（“SELECT * FROM 。。。”） ;
int rows = stmt.executeUpdate（“INSERT INTO 。。。”） ;
boolean flag = stmt.execute（String sql） ;
6、处理结果
两种情况：
1、执行更新返回的是本次操作影响到的记录数。
2、执行查询返回的结果是一个ResultSet对象。
• ResultSet包含符合SQL语句中条件的所有行，并且它通过一套get方法提供了对这些
行中数据的访问。
• 使用结果集（ResultSet）对象的访问方法获取数据：
while（rs.next（））{
String name = rs.getString（“name”） ;
String pass = rs.getString（1） ; // 此方法比较高效
}
（列是从左到右编号的，并且从列1开始）
7、关闭JDBC对象
操作完成以后要把所有使用的JDBC对象全都关闭，以释放JDBC资源，关闭顺序和声明顺序相反：
1、关闭记录集
2、关闭声明
3、关闭连接对象
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（） ;
}
}
8、实例：JdbcUtils
我将他们封装到一个类中，并进行了测试。代码中解释很详细，我就不再进行解释了。
package com.jdbc.dbutils;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class JdbcUtils {
/**
* 数据库的用户名
*/
private final String USER = “root”;
/**
* 数据库的密码
*/
private final String PASSWORD = “123456”;
/**
* 数据库的驱动信息
*/
private final String DRIVER = “com.mysql.jdbc.Driver”;
/**
* 访问数据库的地址
*/
private final String URL = “jdbc:mysql://localhost:3306/test”;
/**
* 数据库的连接
*/
Connection connection;
/**
* sql语句的执行对象
*/
PreparedStatement preparedStatement;
/**
* 查询返回的结果集合
*/
ResultSet resultSet;
public JdbcUtils（） {
try {
Class.forName（DRIVER）;
System.out.println（“注册驱动成功”）;
} catch （ClassNotFoundException e） {
e.printStackTrace（）;
}
}
/**
* 连接数据库
*
* @return 数据库的连接对象
*/
public Connection getConnection（） {
try {
connection = DriverManager.getConnection（URL， USER， PASSWORD）;
} catch （SQLException e） {
e.printStackTrace（）;
}
return connection;
}
/**
* 完成对数据库的表的添加删除和修改的操作
*
* @param sql
* @param params
* @return
* @throws SQLException
*/
public boolean updateByPrepareStatement（String sql， List《Object> params）
throws SQLException {
boolean flag = false;
int result = -1;// 表示当用户执行添加删除和修改的时候所影响数据库的行数
// 创建一个 PreparedStatement 对象来将参数化的 sql 语句发送到数据库。
preparedStatement = connection.prepareStatement（sql）;
int index = 1;
if （params ！= null && ！params.isEmpty（）） {
for （Object object ： params） {
// 使用给定对象设置指定参数的值。index从1开始
preparedStatement.setObject（index++， object）;
}
}
// 在此 PreparedStatement 对象中执行 SQL 语句，该语句必须是一个 SQL 数据操作语言语句，比如
// INSERT、UPDATE 或 DELETE 语句
result = preparedStatement.executeUpdate（）;
flag = result > 0 ？ true ： false;
return flag;
}
/**
* 查询返回单条记录
*
* @param sql
* @param params
* @return
* @throws SQLException
*/
public Map
throws SQLException {
Map
int index = 1;
// 创建一个 PreparedStatement 对象来将参数化的 sql 语句发送到数据库。
preparedStatement = connection.prepareStatement（sql）;
if （params ！= null && ！params.isEmpty（）） {
for （Object object ： params） {
// 使用给定对象设置指定参数的值。index从1开始
preparedStatement.setObject（index++， object）;
}
}
// 在此 PreparedStatement 对象中执行 SQL 查询，并返回该查询生成的 ResultSet 对象。
resultSet = preparedStatement.executeQuery（）;
// 获取此 ResultSet 对象的列的编号、类型和属性。
ResultSetMetaData metaData = resultSet.getMetaData（）;
int col_len = metaData.getColumnCount（）;
while （resultSet.next（）） {
for （int i = 0; i
// sql数据库列的下标是从1开始的
String col_name = metaData.getColumnName（i + 1）;
Object col_value = resultSet.getObject（col_name）;
if （col_value == null） {
col_value = “”;
}
map.put（col_name， col_value）;
}
}
return map;
}
public List
List
List
int index = 1;
// 创建一个 PreparedStatement 对象来将参数化的 sql 语句发送到数据库。
preparedStatement = connection.prepareStatement（sql）;
if （params ！= null && ！params.isEmpty（）） {
for （Object object ： params） {
// 使用给定对象设置指定参数的值。index从1开始
preparedStatement.setObject（index++， object）;
}
}
// 在此 PreparedStatement 对象中执行 SQL 查询，并返回该查询生成的 ResultSet 对象。
resultSet = preparedStatement.executeQuery（）;
// 获取此 ResultSet 对象的列的编号、类型和属性。
ResultSetMetaData metaData = resultSet.getMetaData（）;
int col_len = metaData.getColumnCount（）;
while （resultSet.next（）） {
Map
for （int i = 0; i < col_len; i++） {
// sql数据库列的下标是从1开始的
String col_name = metaData.getColumnName（i + 1）;
Object col_value = resultSet.getObject（col_name）;
if （col_value == null） {
col_value = “”;
}
map.put（col_name， col_value）;
}
list.add（map）;
}
return list;
}
/**
* 关闭数据库
*
* @throws SQLException
*/
public void releaseConn（） throws SQLException {
if （resultSet ！= null） {
resultSet.close（）;
}
if （preparedStatement ！= null） {
preparedStatement.close（）;
}
if （connection ！= null） {
connection.close（）;
}
}
static JdbcUtils jdbcUtils;
public static void main（String［］ args） throws SQLException {
jdbcUtils = new JdbcUtils（）;
jdbcUtils.getConnection（）;
// insert（）;
// update（）;
// query（）;
Morequery（）;
}
private static void query（） throws SQLException {
String sql = “select * from userinfo where pwd = ？ ”;
List
params.add（“123”）;
Map
System.out.println（map）;
}
private static void Morequery（） throws SQLException {
String sql = “select * from userinfo ”;
List
System.out.println（map）;
}
/**
* 更新数据库内容
*
* @throws SQLException
*/
private static void update（） throws SQLException {
String sql = “update userinfo set username =？ where id=2”;
List
params.add（“liumr”）;
jdbcUtils.updateByPrepareStatement（sql， params）;
}
/**
* 增加数据
*
* @throws SQLException
*/
private static void insert（） throws SQLException {
String sql = “insert userinfo （username，pwd） values （？，？）”;
List
params.add（“liugx”）;
params.add（“456”）;
jdbcUtils.updateByPrepareStatement（sql， params）;
}
}
工商网监
评论