JDBC学习系列：使用JDBC对数据库进行CRUD
1、statement对象介绍
Jdbc中的statement对象用于向数据库发送SQL语句，想完成对数据库的增删改查，只须要经过这个对象向数据库发送增删改查语句便可。
Statement对象的executeUpdate方法，用于向数据库发送增、删、改的sql语句，executeUpdate执行完后，将会返回一个整数(即增删改语句致使了数据库几行数据发生了变化)。
Statement.executeQuery方法用于向数据库发送查询语句，executeQuery方法返回表明查询结果的ResultSet对象。html
1.一、CRUD操做-create
使用executeUpdate(String sql)方法完成数据添加操做，示例操做：java
1 Statement st = conn.createStatement();
2 String sql = "insert into user(….) values(…..) ";
3 int num = st.executeUpdate(sql);
4 if(num>0){
5 System.out.println("插入成功！！！");
6 }
1.二、CRUD操做-update
使用executeUpdate(String sql)方法完成数据修改操做，示例操做：mysql
1 Statement st = conn.createStatement();
2 String sql = “update user set name=‘’ where name=‘’";
3 int num = st.executeUpdate(sql);
4 if(num>0){
5 System.out.println(“修改为功！！！");
6 }
1.三、CRUD操做-delete
使用executeUpdate(String sql)方法完成数据删除操做，示例操做：sql
1 Statement st = conn.createStatement();
2 String sql = “delete from user where id=1;
3 int num = st.executeUpdate(sql);
4 if(num>0){
5 System.out.println(“删除成功！！！");
6 }
1.四、CRUD操做-read
使用executeQuery(String sql)方法完成数据查询操做，示例操做：数据库
1 Statement st = conn.createStatement();
2 String sql = “select * from user where id=1;
3 ResultSet rs = st.executeUpdate(sql);
4 while(rs.next()){
5 //根据获取列的数据类型，分别调用rs的相应方法映射到java对象中
6 }
2、使用jdbc对数据库增删改查
2.一、搭建实验环境
搭建方式仍是和上一篇“JDBC入门”同样，建立好数据库表后，新建JAVAWEB工程并导入mysql驱动，不一样的是此次将数据库链接信息保存在properties文件中，在src目录下新建一个db.properties文件，内容以下：工具
driver=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/sc username=root password=123456
注意：properties文件中不能有空格，不然编译时会报错、url
编写一个JdbcUtils工具类，用于链接数据库，获取数据库链接和释放数据库链接，代码以下：spa
package com.study.jdbc;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
/**
* JDBC工具类，用于链接数据库，获取数据库链接和释放数据库链接
* @author Sam Flynn
*
*/
public class JdbcUtils {
private static String driver = null;
private static String url = null;
private static String username = null;
private static String password = null;
static{
try{
//读取db.properties文件中的数据库链接信息
InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
Properties prop = new Properties();
prop.load(in);
//获取数据库链接驱动
driver = prop.getProperty("driver");
//获取数据库链接URL地址
url = prop.getProperty("url");
//获取数据库链接用户名
username = prop.getProperty("username");
//获取数据库链接密码
password = prop.getProperty("password");
//加载数据库驱动
Class.forName(driver);
}catch (Exception e) {
throw new ExceptionInInitializerError(e);
}
}
/**
* @Method: getConnection
* @Description: 获取数据库链接对象
*
* @return Connection数据库链接对象
* @throws SQLException
*/
public static Connection getConnection() throws SQLException{
return DriverManager.getConnection(url, username,password);
}
/**
* @Method: release
* @Description: 释放资源，
* 要释放的资源包括Connection数据库链接对象，负责执行SQL命令的Statement对象，存储查询结果的ResultSet对象
*
* @param conn
* @param st
* @param rs
*/
public static void release(Connection conn,Statement st,ResultSet rs){
if(rs!=null){
try{
//关闭存储查询结果的ResultSet对象
rs.close();
}catch (Exception e) {
e.printStackTrace();
}
rs = null;
}
if(st!=null){
try{
//关闭负责执行SQL命令的Statement对象
st.close();
}catch (Exception e) {
e.printStackTrace();
}
}
if(conn!=null){
try{
//关闭Connection数据库链接对象
conn.close();
}catch (Exception e) {
e.printStackTrace();
}
}
}
}
2.二、使用statement对象完成对数据库的CRUD操做
package com.study.jdbc;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
/**
* JDBC使用Statement对象对数据库进行CRUD操做
* @author Sam Flynn
*
*/
public class JdbcCRUD {
public static void insert(){
Connection conn = null;
Statement st = null;
ResultSet rs = null;
try{
//获取一个数据库链接
conn = JdbcUtils.getConnection();
//经过conn对象获取负责执行SQL命令的Statement对象
st = conn.createStatement();
//要执行的SQL命令
String sql = "insert into course(cname,ctime) values('法律学',6)";
//执行插入操做，executeUpdate方法返回成功的条数
int num = st.executeUpdate(sql);
if(num>0){
System.out.println("插入成功！！");
}
}catch (Exception e) {
e.printStackTrace();
}finally{
//SQL执行完成以后释放相关资源
JdbcUtils.release(conn, st, rs);
}
}
public static void delete(){
Connection conn = null;
Statement st = null;
ResultSet rs = null;
try{
conn = JdbcUtils.getConnection();
String sql = "delete from course where cno=6";
st = conn.createStatement();
int num = st.executeUpdate(sql);
if(num>0){
System.out.println("删除成功！！");
}
}catch (Exception e) {
e.printStackTrace();
}finally{
JdbcUtils.release(conn, st, rs);
}
}
public static void update(){
Connection conn = null;
Statement st = null;
ResultSet rs = null;
try{
conn = JdbcUtils.getConnection();
String sql = "update course set ctime=7 where cno=1";
st = conn.createStatement();
int num = st.executeUpdate(sql);
if(num>0){
System.out.println("更新成功！！");
}
}catch (Exception e) {
e.printStackTrace();
}finally{
JdbcUtils.release(conn, st, rs);
}
}
public static void find(){
Connection conn = null;
Statement st = null;
ResultSet rs = null;
try{
conn = JdbcUtils.getConnection();
String sql = "select * from course where cno=3";
st = conn.createStatement();
rs = st.executeQuery(sql);
if(rs.next()){
System.out.println(rs.getString("cname"));
}
}catch (Exception e) {
e.printStackTrace();
}finally{
JdbcUtils.release(conn, st, rs);
}
}
}
3、PreparedStatement对象介绍
PreperedStatement是Statement的子类，它的实例对象能够经过调用Connection.preparedStatement()方法得到，相对于Statement对象而言：PreperedStatement能够避免SQL注入的问题。
Statement会使数据库频繁编译SQL，可能形成数据库缓冲区溢出。PreparedStatement可对SQL进行预编译，从而提升数据库的执行效率。而且PreperedStatement对于sql中的参数，容许使用占位符的形式进行替换，简化sql语句的编写。code
3.一、使用PreparedStatement对象完成对数据库的CRUD操做
package com.study.jdbc;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
/**
* 使用PreparedStatement对象对数据库进行CRUD
* @author Sam Flynn
*
*/
public class PreparedStatementCRUD {
public static void insert(){
Connection conn = null;
PreparedStatement st = null;
ResultSet rs = null;
try{
//获取一个数据库链接
conn = JdbcUtils.getConnection();
//要执行的SQL命令，SQL中的参数使用?做为占位符
String sql = "insert into course(cname,ctime) values(?,?)";
//经过conn对象获取负责执行SQL命令的prepareStatement对象
st = conn.prepareStatement(sql);
//为SQL语句中的参数赋值，注意，索引是从1开始的
st.setString(1, "法律学");//cname是varchar(字符串类型)
st.setInt(2,6);//ctime是varchar(字符串类型)
//执行插入操做，executeUpdate方法返回成功的条数
int num = st.executeUpdate();
if(num>0){
System.out.println("插入成功！！");
}
}catch (Exception e) {
e.printStackTrace();
}finally{
//SQL执行完成以后释放相关资源
JdbcUtils.release(conn, st, rs);
}
}
public static void delete(){
Connection conn = null;
PreparedStatement st = null;
ResultSet rs = null;
try{
conn = JdbcUtils.getConnection();
String sql = "delete from course where cno=?";
st = conn.prepareStatement(sql);
st.setInt(1, 7);
int num = st.executeUpdate();
if(num>0){
System.out.println("删除成功！！");
}
}catch (Exception e) {
e.printStackTrace();
}finally{
JdbcUtils.release(conn, st, rs);
}
}
public static void update(){
Connection conn = null;
PreparedStatement st = null;
ResultSet rs = null;
try{
conn = JdbcUtils.getConnection();
String sql = "update course set ctime=? where cno=?";
st = conn.prepareStatement(sql);
st.setInt(1,3);
st.setInt(2,1);
int num = st.executeUpdate();
if(num>0){
System.out.println("更新成功！！");
}
}catch (Exception e) {
e.printStackTrace();
}finally{
JdbcUtils.release(conn, st, rs);
}
}
public static void find(){
Connection conn = null;
PreparedStatement st = null;
ResultSet rs = null;
try{
conn = JdbcUtils.getConnection();
String sql = "select * from course where cno=?";
st = conn.prepareStatement(sql);
st.setInt(1, 2);
rs = st.executeQuery();
if(rs.next()){
System.out.println(rs.getString("cname"));
}
}catch (Exception e) {
}finally{
JdbcUtils.release(conn, st, rs);
}
}
}
参考资料：xml
相关文章
- 1. 使用JDBC对数据库进行CRUD
- 2. 深刻分析JavaWeb Item28 -- 使用JDBC对数据库进行CRUD
- 3. 使用JDBC对数据库进行CRUD（二）
- 4. 使用JDBC对数据库进行CRUD的操做
- 5. 使用JDBC对数据库进行CRUD（转）
- 6. 深刻分析JavaWeb 28 -- 使用JDBC对数据库进行CRUD
- 7. javaweb学习总结(三十三)——使用JDBC对数据库进行CRUD
- 8. JavaWeb学习总结(三十三)——使用JDBC对数据库进行CRUD
- 9. jdbc对数据库的CRUD操做
- 10. JavaWeb学习心得之JDBC对数据库CRUD
- 更多相关文章...
- • 使用TCP协议进行路由跟踪 - TCP/IP教程
- • 使用UDP协议进行路由跟踪 - TCP/IP教程
- • 适用于PHP初学者的学习线路和建议
- • Flink 数据传输及反压详解
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. 安装cuda+cuDNN
- 2. GitHub的使用说明
- 3. phpDocumentor使用教程【安装PHPDocumentor】
- 4. yarn run build报错Component is not found in path “npm/taro-ui/dist/weapp/components/rate/index“
- 5. 精讲Haproxy搭建Web集群
- 6. 安全测试基础之MySQL
- 7. C/C++编程笔记：C语言中的复杂声明分析，用实例带你完全读懂
- 8. Python3教程(1)----搭建Python环境
- 9. 李宏毅机器学习课程笔记2：Classification、Logistic Regression、Brief Introduction of Deep Learning
- 10. 阿里云ECS配置速记
欢迎关注本站公众号,获取更多信息
相关文章