使用JDBC连接MySQL数据库-典型案例分析(1)-员工数据读取与操作

使用JDBC连接MySQL数据库--典型案例分析(一)---员工数据读取与操作

使用JDBC连接MySQL数据库,查询emp表中所有员工的ID,姓名,薪资,以及入职时间。

方案:

1.装载驱动程序

在此,需要使用MySql数据库的驱动类,代码如下:

private static final String driver = "com.mysql.jdbc.Driver"; //数据库驱动

class.forName(driver);

2.建立连接

建立连接时,连接的字符串格式为:

//连接数据库的URL地址
private static final String url="jdbc:mysql://localhost:3306/emp?useUnicode=true&characterEncoding=UTF-8"; 
private static final String username="wonderq";//数据库的用户名
private static final String password="root";//数据库的密码

private static Connection conn=DriverManager.getConnection(url, username, password);其中getConnection方法有三个参数,第一个参数表示连接数据库的字符串格式URL,它包含了要连接的数据库的信息,李茹本案例中连接MySql数据库的连接字符串格式为:

jdbc:mysql://<主机名>:<端口号(默认3306)>/数据库名

第二个参数表示连接数据库的用户名,第三个参数表示连接数据库的密码,可以根据连接数据库的不同,用户名和密码的不同,相应的修改以上所属的三个参数。

3.发送和执行SQL语句

首先通过Connection的createStatement()方法获取数据库操作对象Statement,代码如下:

Statement stmt=con.createStatement();

Statement主要用于执行SQL语句并返回它所生成的结果。通过调用它的executeQuery方法来执行SQL语句

 ResultSet rs=stmt.executeQuery("select empno,ename,sal,hiredate from emp");

其中,executeQuery方法有一个参数,表示要执行的SQL语句,该方法返回值为ResultSet类型的对象。ResultSet表示数据库查询操作的结果集。它具有指向其当前数据行的光标。最初,光标被置于第一行之前,调用其next方法将光标移动到下一行,该方法在ResultSet对象没有下一行时返回false,因此可以在while循环中使用它来迭代结果集。代码如下所示:

while(rs.next()){

System.out.println(rs.getInt("empno")+","+rs.getString("ename")+","+rs.getDouble("sal")+","+rs.getDate("hiredate"));

}

从上述代码中看出了ResultSet提供了getXXX(String column)方法,例如getInt(String column)等,获取当前ResultSet对象的当前行中指定列名的的值,其中参数colunm表示数据库表中的列名字。

另外,ResultSet提供了getXXX(int columnIndex)方法,例如:getInt(int columnIndex)等,获取当前ResultSet对象当前行中指定列索引的值,其中参数colunmnIndex表示要获取的列的数据在表中是第几列,注意:列数从1开始,这里建议使用根据列名去获取列的信息。

4.释放资源

数据库的连接资源是有限的,使用完毕后需要及时释放。否则会因资源耗尽应用程序瘫痪,无法正常工作。调用JDBC对象的close方法即可释放与该对象关联的系统资源。代码如下:

if(rs!=null){

rs.close();

}

if(stmt!=null){

stmt.close();

}

if(con!=null){

con.close();

}

步骤

实现此案例需要按照如下步骤进行。

步骤一:在Mysql数据库中,创建emp表并插入测试数据

SQL语句如下:

create table emp(

empno int(4),

ename varchar(10),

job varchar(9),

mgr int(4),

hiredate Date,

sal double(7,2),

comm double(7,2),

deptno double(2,0)

);

INSERT INTO emp VALUES(7369,'smith','clerk',7902,'1980-12-17',800,NULL,20);
INSERT INTO emp VALUES(7499,'allen','salesman',7698,'1981-2-20',1600,300,30);
INSERT INTO emp VALUES(7521,'ward','salesman',7698,'1981-2-22',1250,500,30);
INSERT INTO emp VALUES(7566,'jones','manager',7839,'1981-4-8',2975,NULL,20);
INSERT INTO emp VALUES(7654,'martin','salesman',7698,'1981-9-21',1200,1400,30);
INSERT INTO emp VALUES(7698,'blake','manger',7839,'1981-5-1',2850,NULL,30);
INSERT INTO emp VALUES(7782,'claek','manger',7839,'1981-6-9',2450,NULL,10);
INSERT INTO emp VALUES(7788,'scott','analsy',7566,'1987-4-19',3000,NULL,20);
INSERT INTO emp VALUES(7839,'king','president',NULL,'1981-11-17',5000,NULL,10);


数据结果预览:

使用JDBC连接MySQL数据库-典型案例分析(1)-员工数据读取与操作

使用JDBC连接MySQL数据库-典型案例分析(1)-员工数据读取与操作

步骤二:

在当前工程下读入连接MySql数据库对应的驱动程序jar包

步骤三:重构EmpDAO类

重构EmpDAO类,在该类中使用Mysql数据库的驱动程序和连接MySql数据库的连接字符串格式,代码如下;

package dao;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class EmpDAO {
private static final String driver = "com.mysql.jdbc.Driver"; //数据库驱动
private static final String url="jdbc:mysql://localhost:3306/emp"; 
private static final String username="wonderq";//数据库的用户名
private static final String password="root";//数据库的密码
public static void main(String [] args){
EmpDAO dao=new EmpDAO();
dao.findAll();
}
public void findAll(){
Connection con=null;
Statement stmt=null;
ResultSet rs=null;

try {
Class.forName(driver);
con=DriverManager.getConnection(url, username, password);
stmt=con.createStatement();
rs=stmt.executeQuery("select empno,ename,sal,hiredate from emp;");
while(rs.next()){
System.out.println(rs.getInt("empno")+","+rs.getString("ename")+","+rs.getDouble("sal")+","+rs.getDate("hiredate"));
}
} catch (ClassNotFoundException e) {
System.out.println("驱动类无法找到!");
throw new RuntimeException(e);
}
 catch (SQLException e){
 System.out.println("数据库访问异常!");
 throw new RuntimeException(e);
 }
finally{
try {
if(rs!=null){
rs.close();
}
if(stmt!=null){
stmt.close();
}
if(con!=null){
con.close();
}
} catch (SQLException e) {
System.out.println("关闭连接时发生异常!");
}
}
}
}

  运行EmpDAO类,控制台输出结果如下所示:


7369,smith,800.0,1980-12-17
7499,allen,1600.0,1981-02-20
7521,ward,1250.0,1981-02-22
7566,jones,2975.0,1981-04-08
7654,martin,1200.0,1981-09-21
7698,blake,2850.0,1981-05-01
7782,claek,2450.0,1981-06-09
7788,scott,3000.0,1987-04-19
7839,king,5000.0,1981-11-17


好了,第一部分先做到这里,期待下次的精彩吧,小伙伴使用JDBC连接MySQL数据库-典型案例分析(1)-员工数据读取与操作