`

JDBC基础学习之增删改查(三)

    博客分类：
  • JDBC
CRUDjdbc 
阅读更多

一、准备工作，创建表人员信息表(t_person)、用户表(user)、机构信息表(t_org)

sql脚本：

/*
Navicat MySQL Data Transfer

Source Server         : localhost
Source Server Version : 50162
Source Host           : localhost:3306
Source Database       : demo

Target Server Type    : MYSQL
Target Server Version : 50162
File Encoding         : 65001

Date: 2017-12-02 10:07:32
*/

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for t_org
-- ----------------------------
DROP TABLE IF EXISTS `t_org`;
CREATE TABLE `t_org` (
  `id` int(4) NOT NULL AUTO_INCREMENT,
  `pid` int(4) DEFAULT NULL,
  `name` varchar(100) NOT NULL,
  `description` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of t_org
-- ----------------------------
INSERT INTO `t_org` VALUES ('1', '0', '实施组', '调研、实施');
INSERT INTO `t_org` VALUES ('2', '0', '开发组', '开发');
INSERT INTO `t_org` VALUES ('3', '0', '财务部', '做账、');
INSERT INTO `t_org` VALUES ('4', '0', '人力资源部', '人力资源');

-- ----------------------------
-- Table structure for t_person
-- ----------------------------
DROP TABLE IF EXISTS `t_person`;
CREATE TABLE `t_person` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `oid` int(4) DEFAULT NULL,
  `name` varchar(100) NOT NULL,
  `sex` char(1) NOT NULL,
  `address` varchar(200) DEFAULT NULL,
  `age` int(4) DEFAULT NULL,
  `phone` varchar(11) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of t_person
-- ----------------------------
INSERT INTO `t_person` VALUES ('1', '1', '张三', '1', 'xxxxx', '20', '13984848326');
INSERT INTO `t_person` VALUES ('2', '1', '张飞', '1', 'xxxxx', '22', '10086');
INSERT INTO `t_person` VALUES ('3', '2', '杨过', '1', 'xxxxx', '25', '10000');
INSERT INTO `t_person` VALUES ('4', '3', '小龙女', '0', 'xxxxx', '25', '10086');

-- ----------------------------
-- Table structure for user
-- ----------------------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
  `id` int(4) NOT NULL,
  `pid` int(11) DEFAULT NULL,
  `user_name` varchar(50) NOT NULL,
  `password` varchar(50) DEFAULT NULL,
  `create_time` bigint(20) DEFAULT NULL,
  `expired_time` bigint(20) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO `user` VALUES ('1', '1', 'zhangsan', '123456', null, null);
INSERT INTO `user` VALUES ('2', '2', 'zhangfei', '123456', null, null);
INSERT INTO `user` VALUES ('3', '3', 'yangguo', '123456', null, null);
INSERT INTO `user` VALUES ('4', '4', 'xiaolongnv', '123456', null, null);

 二、查询出人员表中的所有信息

public class Test {

	public static void main(String[] args) {
		Connection conn = null;
		String url = "jdbc:mysql://127.0.0.1:3306/demo";
		String user = "root";
		String password = "root_123";
		ResultSet rs = null;
		Statement stmt = null;
		try {
			// 第一步：加载驱动
			Class.forName("com.mysql.jdbc.Driver");
			// 第二步：得到链接
			conn = DriverManager.getConnection(url, user, password);
			//第三步：创建执行SQL语句的statement
			stmt = conn.createStatement();
			String sql = "select * from t_person";
			//第四步：处理执行的结果
			rs = stmt.executeQuery(sql);
			while (rs.next()) {
				StringBuffer sb = new StringBuffer();
				sb.append("id:" + rs.getInt("id") + "\t")
				  .append("name:" + rs.getString("name")  + "\t")
				  .append("address:" + rs.getString("address")  + "\t")
				  .append("sex:" + rs.getString("sex")  + "\t")
				  .append("age:" + rs.getInt("age")  + "\t")
				  .append("phone:" + rs.getString("phone")  + "\t");
				System.out.println(sb.toString());
			}

		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
			//第五步：释放资源
			if(null != rs){
				try {
					rs.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
			if(null != stmt){
				try {
					stmt.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
			if(null != conn){
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
		}
	}

}

三、创建表t_test

 

public class Test2 {

	public static void main(String[] args) {
		Connection conn = null;
		Statement stmt = null;
		String url = "jdbc:mysql://127.0.0.1:3306/demo";
		String user = "root";
		String password = "root_123";
		try {
			//第一步：加载驱动
			Class.forName("com.mysql.jdbc.Driver");
			//第二步：得到链接
			conn = DriverManager.getConnection(url, user, password);
			//第三步：创建执行SQL的statement语句
			stmt = conn.createStatement();
			StringBuffer sbSql = new StringBuffer();
			sbSql.append("create table t_test( ")
				 .append("id int(4) primary key not null, ")
				 .append("user_name varchar (20) not null ")
				 .append(");");
			stmt.executeUpdate(sbSql.toString());
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
			//第四步：释放资源
			if(null != stmt){
				try {
					stmt.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
			if(null != conn){
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
		}
	}
}

 思考：举一反三，大家可以尝试下删除、修改之类的操作。

四、连接数据库的工具类DBUtil

 

由于对数据库常见的操作是CRUD，并且进行操作时基本的步骤都相似，因此我们把数据库的连接和资源的关闭进行封装.

 

package com.zlt.jdbc.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * 将数据库的连接以及资源的释放封装成一个通用的工具类
 * 
 * @author 涛声一笑 289836653
 *
 */
public class DBUtil {

	/**
	 * 得到数据库连接
	 * @return
	 */
	public static Connection getConnection() {
		Connection conn = null;
		String url = "jdbc:mysql://127.0.0.1:3306/demo";
		String user = "root";
		String password = "root_123";
		try {
			Class.forName("com.mysql.jdbc.Driver");
			conn = DriverManager.getConnection(url, user, password);
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return conn;
	}

	/**
	 * 释放结果集资源
	 * @param rs
	 */
	public static void close(ResultSet rs){
		if(null != rs) {
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
	
	/**
	 * 释放执行SQL的statement资源
	 * @param stmt
	 */
	public static void close(Statement stmt){
		if(null != stmt) {
			try {
				stmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		} 
	}
	
	
	/**
	 * 释放数据库连接Connection
	 * @param conn
	 */
	public static void close(Connection conn){
		if(null != conn) {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
}

 单元测试

package com.zlt.jdbc.util;

import junit.framework.TestCase;

public class DBUtilTest extends TestCase {
	protected void setUp() throws Exception {
		super.setUp();
	}
	public void testGetConnection() {
		System.out.println(DBUtil.getConnection());
	}
}

 五、将查询的结果与JAVA对象模型联系起来

         5.1建立对象模型(JavaBean)

package com.zlt.jdbc;

/**
 * 建立关系模型与对象模型之间的映射
 * 对象模型实体Person与关系模型t_person（暂不考虑关系与关系之间的关联）
 * @author 涛声一笑  289836653
 *
 */
public class Person {
	
	private int id;
	private int oid;
	private String name;
	private String sex;
	private String address;
	private int age;
	private String phone;
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public int getOid() {
		return oid;
	}
	public void setOid(int oid) {
		this.oid = oid;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getSex() {
		return sex;
	}
	public void setSex(String sex) {
		this.sex = sex;
	}
	public String getAddress() {
		return address;
	}
	public void setAddress(String address) {
		this.address = address;
	}
	public int getAge() {
		return age;
	}
	public void setAge(int age) {
		this.age = age;
	}
	public String getPhone() {
		return phone;
	}
	public void setPhone(String phone) {
		this.phone = phone;
	}		
}

 

    5.2根据人员ID查询出人员信息

package com.zlt.jdbc;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.zlt.jdbc.util.DBUtil;

public class Test3 {

	public static void main(String[] args) {
		Person p = findPersonById(1);
		System.out.println("id:" + p.getId() +"name:" +p.getName() + "age:" + p.getAge() + "sex:" + p.getSex() + "oid:" + p.getOid() + "address:" + p.getAddress() +"phone:" + p.getPhone());
	}
	
	/**
	 * 根据人员ID查询出人员的信息
	 * （建议平时写代码时先把SQL语句调通）
	 * select id,oid,name,sex,age,address,phone from t_person
	 * @param id 人员ID
	 * @return p,p为null时表示没查询到 
	 */
	public static Person findPersonById(int id){
		Person p = null;
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		try {
			conn  = DBUtil.getConnection();
			stmt = conn.createStatement();
			String sql = "select id,oid,name,sex,age,address,phone from t_person";
			rs = stmt.executeQuery(sql);
			if(rs.next()) {
				p = new Person();
				p.setId(rs.getInt("id"));
				p.setName(rs.getString("name"));
				p.setOid(rs.getInt("oid"));
				p.setSex(rs.getString("sex"));
				p.setAge(rs.getInt("age"));
				p.setAddress(rs.getString("address"));
				p.setPhone(rs.getString("phone"));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
			DBUtil.close(stmt);
			DBUtil.close(rs);
			DBUtil.close(conn);
		}
		return p;
	}
}

    5.3查询出姓名为张姓的人员信息

public static List<Person> findPersonByName(String name){
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		List<Person> persons = new ArrayList<Person>();
		try {
			conn  = DBUtil.getConnection();
			stmt = conn.createStatement();
			String sql = "select id,oid,name,sex,age,address,phone from t_person where name like '%"+name+"%'";
			rs = stmt.executeQuery(sql);
			while(rs.next()) {
				Person p = new Person();
				p.setId(rs.getInt("id"));
				p.setName(rs.getString("name"));
				p.setOid(rs.getInt("oid"));
				p.setSex(rs.getString("sex"));
				p.setAge(rs.getInt("age"));
				p.setAddress(rs.getString("address"));
				p.setPhone(rs.getString("phone"));
				persons.add(p);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
			DBUtil.close(stmt);
			DBUtil.close(rs);
			DBUtil.close(conn);
		}
		return persons;
	}

    5.4遗留问题:此时使用Statement执行SQL语句时进行拼串，使用该种语句有两个缺点1）有SQL注入问题 2）当控制条件越多，拼串难度越繁琐

写道
推荐使用PreparedStatement语句，其有效的防止sql注入(SQL语句在程序运行前已经进行了预编译,当运行时动态地把参数传给PreprareStatement时，即使参数里有敏感字符如 or '1=1'也数据库会作为一个参数一个字段的属性值来处理而不会作为一个SQL指令

    5.5使用PrepareStatement语句重写b示例,但是在重写c示例时，发现模糊查询查不出结果但程序没错，因此一般情况下推荐使用P repareStatement，但有时必须使用Statement进行拼串

public static Person findPersonById(int id){
		Person p = null;
		Connection conn = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try {
			conn  = DBUtil.getConnection();
			String sql = "select id,oid,name,sex,age,address,phone from t_person where id = ?" ;
			pstmt = conn.prepareStatement(sql);
			pstmt.setInt(1, id);
			rs = pstmt.executeQuery();
			if(rs.next()) {
				p = new Person();
				p.setId(rs.getInt("id"));
				p.setName(rs.getString("name"));
				p.setOid(rs.getInt("oid"));
				p.setSex(rs.getString("sex"));
				p.setAge(rs.getInt("age"));
				p.setAddress(rs.getString("address"));
				p.setPhone(rs.getString("phone"));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}finally{
			DBUtil.close(pstmt);
			DBUtil.close(rs);
			DBUtil.close(conn);
		}
		return p;
	}

   举一反三：

写道
1）查询人员编号为1,3,5的人员信息。
2）查询年龄在20-25之间的人员信息
3）将姓名为小龙女的人的住址、电话分别更新为绝情谷底，10008611
4）往人员信息表中插入一位新人员（5,3,周伯通,1,30,四海为家,10086）
5）将张三和张飞两个人从表中删除
6）查询姓名为杨过的用户信息以及人员信息

 

0
顶
0
踩
分享到：
| JDBC基础学习之使用步骤（二）
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    javaweb+jsp+jdbc+mvc+javabean+简易增删改查

    javaweb+jsp+jdbc+mvc+javabean+简易增删改查 用户：123 密码：123 这是一个及其简易的增删改查 里面有jdbc链接方法 简化版javaweb 适合人群：具备一定编程基础，编程小白 能学到什么： 阅读建议：此资源以开发简化...

    基于BootStrap和SpringBoot的学生信息管理系统，支持增删改查等基础操作，适合个人web开发学习，毕业设计或课设等

    基于BootStrap和SpringBoot的学生信息管理系统，支持增删改查等基础操作，适合个人web开发学习，毕业设计或课设等 以 Maven 架构项目，使用 JSP + Servlet 开发以及 Spring + SpringMVC + MyBatis 框架；采用 c3p0 ...

    jdbc-mysql连接数据库的增删改查功能实现

    jdbc连接数据库的增删改查的功能实现，非常适合刚学新人逐级学习交流的

    javaweb实现增删改查功能(jdbc+servlet+mysql)

    适合刚刚入门javaweb学习的菜鸟 1.jdbc(baseDao+UserDao) ...1.jdbc:jdbc很详细(从头到尾的步骤)(适合jdbc基础不是很好的人群参考) 2.所用到的jar包(jstl+standard+mysql-connector-java-5.1.8-bin)

    尚硅谷jdbc视频教程

    尚硅谷jdbc视频教程，非常基础，适合新手学习

    【动力节点】Java经典教程_JDBC视频教程

    教程名称： 【动力节点】Java经典教程_JDBC视频教程 本套Java视频教程中讲解了Java编程语言如何连接数据库，对数据库中的数据进行增删改查操作，适合于已经学习过Java编程基础以及数据库的同学。Java教程中阐述了...

    基于java基础和JDBC的小型员工管理系统

    实现了员工的增删改查 可以连接数据库 含有数据库脚本 适合Java学习过后的小作业

    【基础练习】jsp+servlet+jdbc 网上购物商系统（带sql脚本）

    往后学习，大家会碰到很多的框架，例如JDBC的配置类不需要自己写，用mybatis就可以做连接和增删改查，例如servlet也会被spring boot的注解所代替，但是归根结底，它们都是要基于这类知识的。我会把我 拓展了的地方写...

    JDBC入门到精通视频教程课堂笔记

    本套视频教程中讲解了Java语言如何连接数据库，对数据库中的数据进行增删改查操作，适合于已经学习过Java编程基础以及数据库的同学。Java教程中阐述了接口在开发中的真正作用，JDBC规范制定的背景，JDBC编程六部曲，...

    Java后端学习路线 （详细路线）

    重点知识点：基本的增删改查、SQL命令，索引、存储过程、JDBC。 主流的数据库有MySQL、Oracle、SQL Server等等，你只需要搞定一个就可以了，知识都是相通的，一通百通。目前公司里用到MySQL的比较多，所以建议大家...

    Java学习指南(8) MySQL数据库与JDBC框架

    * JDBC连接: 使用JDBC连接数据库，执行增删改查操作 *?基于JDBC数据库框架的设计（afsql框架），以此阐述数据库框架的设计原理* JDBC连接池，JDBC数据库开发的必备技术 *?数据库事务 Transaction 的支持? * SQL的...

    JdbcSunQuickArrayTool.jar

    自己使用Java编写的一个JDBC工具类,支持增删改查操作,功能比较方便,仅供学习参考,毕竟刚刚开始学习JDBC,但基础的功能都实现了

    java必了解的六大问题

    *第四阶段：数据库SQL基础，包括增删改查操作以及多表查询； *第五阶段：JDBC编程：包括JDBC原理，JDBC连接库，JDBC API，虽然现在Hibernate比JDBC要方便许多，但是JDBC技术仍然在使用，JDBC思想尤为重要； *第...

    基于Servlet和JSP的Java后台管理系统设计源码

    该项目是一个使用Web基础知识编写的后台管理系统，采用了Servlet、JSP、JDBC和bootstrap（Ace Admin模板）等技术，页面设计精美，包含文章的增删改查等功能，具有很强的可重用性，适合用于学习和实践Java Web开发...

    java ee 实验一

    实验要求：参考第八章jdbc例子编写几个jsp页面实现数据库的连接，增删改查四个操作（数据库可用access），数据表和页面内容自定义，不统一要求。 提高篇：心有余力的同学在完成以上任务之后还可以写个javabean来实现...

    基于 SpringBoot + ShardingSphere（Sharding-JDBC） 的水平分表测试项目+源代码+文档说明

    - 不分片时，使用默认数据源的增、删、改、查 - 分片时，使用`ShardingDataSource`数据源的增、删、改、查 - 分片表与不分片表的连表查询 - 分片表的分页查询 - 单路由单个字段的查询 ...

    基于Mysql+Java的进销存信息管理系统源码+sql数据库+项目说明.zip

    这个项目比较简单，界面使用的swing，主要也就用到JDBC的相关技术,用到了连接池技术dbcp，数据的增删改查都写在了Dao层，由于项目比较小，并没有一个表对应一个Dao，都写在一个Dao里，比较方便像一些insert（String...

    基于SpringBoot+Hibernate+Shiro的库存管理系统+源代码+文档说明

    * 数据持久层使用SpringBoot自带的Hibernate来维护PO（Persistent Object持久化对象），这里使用Hibernate的原因在于其三种对象状态（持久态、游离态、分割态）便于持久化对象的增删改查等一系列操作，取代了jdbc的...

    Struts2开发最简单学生后台管理系统

    使用了Struts2.3.24版本，做了个简单的增删改查，登录拦截器，防止URL输入。适合基础的同学学习交流。 运行环境 jdk7(8)+tomcat7(8)+mysql+IntelliJ IDEA 项目技术(必填) struts2+jdbc+struts-tags+拦截器

    javaweblearn:javaweb学习

    Chapter3 使用了smartframework框架，实现基本的展示功能，普通网页与数据的增删改查。smartframework 实现设计了一个简单的MVC框架，然后逐步实现了AOP。部分测试模块中展示了一步一步实现了proxy与aop、asp的过程...

Magicbox
Global site tag (gtag.js) - Google Analytics