数据连接步骤
- 注册驱动(只做一次)
- 建立连接(Connection)
- 创建执行SQL的语句(Statament)
- 执行语句
- 处理执行结果(Result)
- 释放资源
1.JDBC连接数据库
a.加载JDBC驱动程序
在连接数据库之前,首先要加载想要连接的数据库驱动到JVM通常使用
b.java.lang.Class类的静态方法forName实现
- 推荐使用这种方式不会对具体的驱动类产生依赖
Class.forName("com.mysql.jdbc.Driver"); - 会造成DriverManager中产生一两个一样的驱动,并会对驱动类产生依赖
DriverManager.registerDriver(com.mysql.jdbc.Driver); - 虽然不会产生具体的驱动类产生依赖,但是注册不太方便,基本不使用
System.setPropertry("jdb.drivers","driver1:driver2");例如:
成功加载后,会将Driver类的实例注册到DriverManager类中.try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { System.out.println("找不到驱动类,注册失败!"); e.printStackTrace(); } }
2.建立连接(Connection)
- 连接url定义了连接数据库时的协议/子协议/数据源标识.
- 书写格式:JDBC:子协议:子名称//主机名:端口/数据库名称?属性名=属性值&.....
协议:在JDBC中总是以jdbc开始 子协议:是桥连接驱动程序或是数据库管理系统名称. user,password可以用"属性名=属性值"方式告诉数据库. 例如: "jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8";
######创建连接数据库
- 要连接数据库,需要向DriverManager请求并获得Connection对象,该对 象就代表一个数据库的连接
- 使用DriverManager的getConnection(String url,String username,String password)方法传入指定要连接的数据库的路径,用户名和密码
例如:
//连接mysql 数据库,用户名root.密码0000
String url = "jdbc:mysql://localhost:3306/test";
String username = "root";
Stringpassword = "0000";
try{
Connection conn =
DriverManager.getConnection(url , username , password ) ;
}catch(SQLException se){
System.out.println("数据库连接失败！");
se.printStackTrace() ;
}
#####3.创建执行SQL语句(Statement)
要执行SQL语句,必须获得java.sql.Statement实例,Statement实例分为以下3种类型
- 执行静态SQL语句,通常使用Statement实例实现,
- 执行动态SQL语句,通常使用PreparedStatement实例实现,
- 执行数据库存储过程,通常使用CallableStatement实例实现.
######具体实现方式如下:
Statement
- Statement st = conn.createStatement();
- st.executeQuery(sql);
PrepasredStatement
- String sql = "select * from user where name = ?";
- PreparedStatement ps = conn.PreparedStatement(sql);
- ps.setString(1,"col_value");
- ps.executeQuery();
CallableStatement
- CallableStatement cst = conn.prepareCall("{CALL demoSp(?,?)}");
####4.执行SQL语句
Statement接口提供了三种SQL语句的方法:executeQuery,executeUpdate,execute.
- ResultSet executeQuery(String sqlString):执行查询数据库的SQL语句,返回一个结果集对象
- int executeUpdate(String sqlString):用于执行insert,update或者delete以及执行SQL语句,如:create table和drop table等.
######实现代码
String sql = "select id,name,password,email,birthday from user";
ResultSet rs = st.executeQuery(sql);
或者
ResultSet rs = st.executeQuery("select * from user");
以及
int i = st.executeQuery(String sql);
####5.处理执行结果(ResultSet)
两种情况:
a. 执行更新返回本次操作影响到的记录数.
b.执行查询返回的结果是一个ResultSet对象
// 参数中的1是指sql中的列索引,使用列的具体来拿
-
while (rs.next()) {
System.out.println(rs.getObject(1);
while(rs.next){
String name = rs.getString("name");
}
####6.释放资源
操作完成以后要把所有使用的JDBC对象全部关闭,以释放JDBC资源,关闭顺序和开始顺序相反.
数据库连接是非常稀有的资源,用完后必须马上释放,如果Connection不能及时正确关闭导致系统宕机,Connection的使用原则是尽量晚创建,尽量早的释放.
#####关闭顺序:
1.关闭结果集ResultSet
2.关闭声明Statement
3.关闭连接Connection
try {
if (rs != null)
rs.close();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if (st != null)
st.close();
} catch (SQLException e) {
e.printStackTrace();
} finally {
if (conn != null)
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
