文档章节

JDBC学习系列:使用JDBC对数据库进行CRUD

HenrySun
 HenrySun
发布于 2016/10/04 12:48
字数 1651
阅读 25
收藏 5
点赞 0
评论 0

一、statement对象介绍  

  Jdbc中的statement对象用于向数据库发送SQL语句,想完成对数据库的增删改查,只需要通过这个对象向数据库发送增删改查语句即可。
  Statement对象的executeUpdate方法,用于向数据库发送增、删、改的sql语句,executeUpdate执行完后,将会返回一个整数(即增删改语句导致了数据库几行数据发生了变化)。
  Statement.executeQuery方法用于向数据库发送查询语句,executeQuery方法返回代表查询结果的ResultSet对象。

1.1、CRUD操作-create

     使用executeUpdate(String sql)方法完成数据添加操作,示例操作:

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.2、CRUD操作-update

  使用executeUpdate(String sql)方法完成数据修改操作,示例操作:

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.3、CRUD操作-delete

  使用executeUpdate(String 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.4、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 }

二、使用jdbc对数据库增删改查

2.1、搭建实验环境

  搭建方式还是和上一篇“JDBC入门”一样,创建好数据库表后,新建JAVAWEB工程并导入mysql驱动,不同的是这次将数据库连接信息保存在properties文件中,在src目录下新建一个db.properties文件,内容如下:

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/sc
username=root
password=123456

  注意:properties文件中不能有空格,否则编译时会报错、

  编写一个JdbcUtils工具类,用于连接数据库,获取数据库连接和释放数据库连接,代码如下:

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.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);
	        }
	    }
}

三、PreparedStatement对象介绍

  PreperedStatement是Statement的子类,它的实例对象可以通过调用Connection.preparedStatement()方法获得,相对于Statement对象而言:PreperedStatement可以避免SQL注入的问题。
  Statement会使数据库频繁编译SQL,可能造成数据库缓冲区溢出。PreparedStatement可对SQL进行预编译,从而提高数据库的执行效率。并且PreperedStatement对于sql中的参数,允许使用占位符的形式进行替换,简化sql语句的编写。

3.1、使用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);
        }
    }
}

 

参考资料:

  使用JDBC对数据库进行CRUD

本文转载自:http://www.cnblogs.com/xdp-gacl/p/3973886.html

共有 人打赏支持
HenrySun
粉丝 84
博文 110
码字总数 41919
作品 0
深圳
高级程序员
JavaWeb07-HTML篇笔记(二)

1.1 案例一:使用JDBC完成CRUD的操作:1.1.1 需求: 对分类管理使用JDBC进行CRUD的操作. 1.1.2 分析:1.1.2.1 技术分析: 【JDBC的概述】 Ø JDBC:Java DataBase Connectivity Java数据库的连...

我是小谷粒 ⋅ 05/16 ⋅ 0

Spring之jdbc Template实现CRUD操作

Spring为各种持久化技术都提供了简单操作的模板回调。比如jdbc、hibernate、Mybatis以及JPA等。 这里我们就以JDBC为例,看看JDBC template怎么实现CRUD操作。 JdbcTemplate主要提供以下几类方...

Java攻城玩家 ⋅ 05/31 ⋅ 0

sharding-jdbc源码分析—准备工作

原文作者:阿飞Javaer 原文链接:https://www.jianshu.com/p/7831817c1da8 接下来对sharding-jdbc源码的分析基于tag为源码,根据sharding-jdbc Features深入学习sharding-jdbc的几个主要特性...

飞哥-Javaer ⋅ 05/03 ⋅ 0

6.1 Java vs php 优缺点、适用类型

1、上手难度比较 php易学易懂,非技术的人,稍稍学习,可以上手,环境搭建用LAMP/WAMP一键安装包,常见开发工具,phpstorm。 Java则要求理解,Java语法和核心架构(jar包)以及JVM,环境配置也...

产品经理的技术课堂 ⋅ 05/20 ⋅ 0

为什么Python成了开发AI的主流语言?Java系列、Ruby等编程语言不行吗?

导读 说道开发AI的语言,很多人说,不是Python吗?没错,Python是可以开发AI,但是不知道你们有没有想过,真的就只有Python才可以开发AI吗? 其实,像Java、Ruby也是开发AI很好的选择,但是为...

柯西带你学编程 ⋅ 05/29 ⋅ 0

Java程序员必读书单,家族又添新成员

点击关注异步图书,置顶公众号 每天与你分享IT好书 技术干货 职场知识 参与文末话题讨论,每日赠送异步图书。 ——异步小编 有些革命出其不意地吸引了全世界的眼球。Twitter、Linux操作系统和...

异步社区 ⋅ 05/09 ⋅ 0

Java NIO AsynchronousFileChannel

原文链接 , 原文作者:Jakob Jenkov, 翻译:Neil Hao 在Java 7,AsynchronousFileChannel 被添加到了Java NIO中。使用AsynchronousFileChannel可以实现异步地读取和写入文件数据。 创建一个A...

Neil_Hao ⋅ 01/20 ⋅ 0

Java多线程学习(五)线程间通信知识点补充

系列文章传送门: Java多线程学习(一)Java多线程入门 Java多线程学习(二)synchronized关键字(1) java多线程学习(二)synchronized关键字(2) Java多线程学习(三)volatile关键字 Ja...

一只蜗牛呀 ⋅ 04/16 ⋅ 0

【小马哥】Spring Boot系列讲座

这里为大家推荐一个不错的Spring Boot系列讲座,讲师介绍如下: 小马哥,阿里巴巴技术专家,从事十余年Java EE 开发,国内微服务技术讲师。目前主要负责微服务技术推广、架构设计、基础设施、...

杜琪 ⋅ 03/02 ⋅ 0

Java编程基础知识点和技术点归纳

Java是一种可以撰写跨平台应用软件的面向对象的程序设计语言。Java 技术具有卓越的通用性、高效性、平台移植性和安全性,广泛应用于PC、数据中心、游戏控制台、科学超级计算机、移动电话和互...

Java小辰 ⋅ 05/23 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

zblog2.3版本的asp系统是否可以超越卢松松博客的流量[图]

最近访问zblog官网,发现zlbog-asp2.3版本已经进入测试阶段了,虽然正式版还没有发布,想必也不久了。那么作为aps纵横江湖十多年的今天,blog2.2版本应该已经成熟了,为什么还要发布这个2.3...

原创小博客 ⋅ 41分钟前 ⋅ 0

聊聊spring cloud的HystrixCircuitBreakerConfiguration

序 本文主要研究一下spring cloud的HystrixCircuitBreakerConfiguration HystrixCircuitBreakerConfiguration spring-cloud-netflix-core-2.0.0.RELEASE-sources.jar!/org/springframework/......

go4it ⋅ 今天 ⋅ 0

二分查找

二分查找,也称折半查找、二分搜索,是一种在有序数组中查找某一特定元素的搜索算法。搜素过程从数组的中间元素开始,如果中间元素正好是要查找的元素,则搜素过程结束;如果某一特定元素大于...

人觉非常君 ⋅ 今天 ⋅ 0

VS中使用X64汇编

需要注意的是,在X86项目中,可以使用__asm{}来嵌入汇编代码,但是在X64项目中,再也不能使用__asm{}来编写嵌入式汇编程序了,必须使用专门的.asm汇编文件来编写相应的汇编代码,然后在其它地...

simpower ⋅ 今天 ⋅ 0

ThreadPoolExecutor

ThreadPoolExecutor public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, ......

4rnold ⋅ 昨天 ⋅ 0

Java正无穷大、负无穷大以及NaN

问题来源:用Java代码写了一个计算公式,包含除法和对数和取反,在页面上出现了-infinity,不知道这是什么问题,网上找答案才明白意思是负的无穷大。 思考:为什么会出现这种情况呢?这是哪里...

young_chen ⋅ 昨天 ⋅ 0

前台对中文编码,后台解码

前台:encodeURI(sbzt) 后台:String param = URLDecoder.decode(sbzt,"UTF-8");

west_coast ⋅ 昨天 ⋅ 0

实验楼—MySQL基础课程-挑战3实验报告

按照文档要求创建数据库 sudo sercice mysql startwget http://labfile.oss.aliyuncs.com/courses/9/createdb2.sqlvim /home/shiyanlou/createdb2.sql#查看下数据库代码 代码创建了grade......

zhangjin7 ⋅ 昨天 ⋅ 0

一起读书《深入浅出nodejs》-node模块机制

node 模块机制 前言 说到node,就不免得提到JavaScript。JavaScript自诞生以来,经历了工具类库、组件库、前端框架、前端应用的变迁。通过无数开发人员的努力,JavaScript不断被类聚和抽象,...

小草先森 ⋅ 昨天 ⋅ 0

Java桌球小游戏

其实算不上一个游戏,就是两张图片,不停的重画,改变ball图片的位置。一个左右直线碰撞的,一个有角度碰撞的。 左右直线碰撞 package com.bjsxt.test;import javax.swing.*;import j...

森林之下 ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部