三、操作Dept表。
1.使用实体类来封装Dept表。
实体类（pojo类）：其作用是用来封装表中的一条数据。（或：用来封装类的属性和方法）。
表中的一条记录：对应于一个实体。
写实体类：必须写三部分：属性、默认构造方法（无参构造方法）、setter和getter方法。其他方法：用到才写，不用就不写。
package com.lxd.pojo;
import java.io.Serializable;
/**
* 实体类(pojo类)
*
* @author XiangdongLee
*
*/
public class Dept implements Serializable {
private static final long serialVersionUID = 1L;
private Integer deptno;
private String dname;
private String loc;
public Dept() {
super();
}
public Integer getDeptno() {
return deptno;
}
public void setDeptno(Integer deptno) {
this.deptno = deptno;
}
public String getDname() {
return dname;
}
public void setDname(String dname) {
this.dname = dname;
}
public String getLoc() {
return loc;
}
public void setLoc(String loc) {
this.loc = loc;
}
}
代码说明：
（1）创建该类的时候，实现Serializable接口。之后，在该行左侧标黄的部位双击，选择“Add default serial version ID”，即可出现第12行代码。
2.创建数据库工具类，来获得数据库连接与关闭数据库连接。
package com.lxd.dao;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/**
* DBUtil:数据库工具类
*
* @author XiangdongLee
*
*/
public class DBUtil {
/**
* 获得数据库连接
*
* @return
*/
public static Connection getConnection() {
Connection conn = null;
String driverName = "oracle.jdbc.OracleDriver";
String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
String username = "scott";
String password = "tiger";
try {
Class.forName(driverName);
conn = DriverManager.getConnection(url, username, password);
} catch (ClassNotFoundException e) {
System.out.println("加载数据库驱动出错...");
e.printStackTrace();
} catch (SQLException e) {
System.out.println("获得数据库连接出错...");
e.printStackTrace();
}
return conn;
}
/**
* 关闭数据库连接
*
* @param conn
* @param ps
* @param rs
*/
public static void close(Connection conn, PreparedStatement ps, ResultSet rs) {
// 关闭原则:先开后关,后开先关
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (ps != null) {
try {
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
System.out.println(getConnection());
}
}
代码说明：
（1）写getConnection()方法时，先写如下结构：
public static Connection getConnection() {
Connection conn = null;
return conn;
}
因为方法需要返回Connection类型的参数，因此先写出此结构，然后再在内部开始填写代码。
（2）第23行代码：取得数据库驱动程序。
写驱动的时候，先在外面点出oracle.jdbc.OracleDriver，然后剪切入引号中。
另外，11g中的数据库驱动程序为：oracle.jdbc.OracleDriver，10g的数据库驱动程序为：oracle.jdbc.driver.OracleDriver。11g也可以通过10g的方式取得，这是为了向下兼容，但是性能不太好。
（3）第24行代码：url：连接数据库的路径（协议）。
127.0.0.1：该部位填写安装Oracle数据库的计算机的IP地址。127.0.0.1是特殊的地址，是环回地址。（服务器和客户端在同一台机器上，转一圈是客户端，再转一圈又是服务器。）该处，也可以用 localhost，但是不建议用。因为实际开发中，服务器和客户端是不在一台机器上的。
1521：Oracle端口号。每个应用程序都有一个唯一的端口号。通过该端口号可以找到是哪个应用程序。Oracle的端口号默认是1521，如果为了防止黑客攻击，在安装数据库的时候，应该改端口号。
orcl：Oracle实例名。通过实例，可以找到数据库中的表分区。
（4）第25、26行：连接数据库的用户名和密码。注意必须是普通用户。
（5）第29行：加载数据库驱动。
第30行：通过驱动管理器类，获得数据库连接。
（6）第48-73行：关闭数据库。
public static void close(Connection conn, PreparedStatement ps, ResultSet rs) {
// 关闭原则:先开后关,后开先关
try {
rs.close();
ps.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
注意：不能用此写法来关闭。如果先关的，在关闭的时候出了错，后面的也会受影响。
（7）第75-77行：测试类。
3. 创建dao类，来封装Dept表的所有操作（增删改查CRUD）。
package com.lxd.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.newer.pojo.Dept;
/**
* 封装表 DEPT 的所有操作(增删改查 CRUD CreateReadUpdateDelete)
*
* @author XiangdongLee
*
*/
public class DeptDao {
// 成员变量：下面的方法都要用到它们3个，因此提在最前面。
private Connection conn;
private PreparedStatement ps;
private ResultSet rs;
/**
* 查询所有数据
*
* @return
*/
// 查询表：访问的是结果集（多条记录）。——因此要用集合。——用List：先放进去的先出来；允许重复值。
public List<Dept> find() {
List<Dept> depts = new ArrayList<Dept>();
try {
// 1.加载数据库驱动类
// 2.获得数据库连接
conn = DBUtil.getConnection();
// 查询所有记录
// String sql = "select * from dept ";
// 根据条件查询记录
String sql = "select * from dept ";
sql += " where deptno<=30";
// 3.通过操作句柄执行SQL语句
ps = conn.prepareStatement(sql);
// 4.获得结果集
rs = ps.executeQuery();
// 5.处理结果集
while (rs.next()) {
Dept dept = new Dept();
// 根据字段名获得字段值(列的值)
dept.setDeptno(rs.getInt("deptno"));
dept.setDname(rs.getString("dname"));
// 根据字段索引获得字段值(列的值)。下标从 1 开始。
dept.setLoc(rs.getString(3));
// 把每一条数据添加到集合中
depts.add(dept);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 6.关闭结果集
// 7.关闭操作句柄Statement
// 8.关闭连接
DBUtil.close(conn, ps, rs);
}
return depts;
}
/**
* 新增数据
*
* @param dept
* @return
*/
public int add(Dept dept) {
int count = 0;
try {
conn = DBUtil.getConnection();
// ? 使用占位符传参 (下标从 1 开始)
String sql = "insert into dept(deptno,dname,loc) ";
sql += " values(?,?,?)";
ps = conn.prepareStatement(sql);
// 设置 占位符 的参数
ps.setInt(1, dept.getDeptno());
ps.setString(2, dept.getDname());
ps.setString(3, dept.getLoc());
// 执行新增语句
count = ps.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
DBUtil.close(conn, ps, rs);
}
return count;
}
/**
* 修改数据
*
* @param dept
* @return
*/
public int modify(Dept dept) {
int count = 0;
try {
conn = DBUtil.getConnection();
String sql = "update dept set dname=? , loc=? ";
sql += " where deptno=?";
ps = conn.prepareStatement(sql);
ps.setString(1, dept.getDname());
ps.setString(2, dept.getLoc());
ps.setInt(3, dept.getDeptno());
// 执行更新语句
count = ps.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
DBUtil.close(conn, ps, rs);
}
return count;
}
/**
* 删除数据
*
* @param deptno
* @return
*/
public int remove(Integer deptno) {
int count = 0;
try {
conn = DBUtil.getConnection();
String sql = "delete dept where deptno=?";
ps = conn.prepareStatement(sql);
ps.setInt(1, deptno);
// 执行更新语句
count = ps.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
DBUtil.close(conn, ps, rs);
}
return count;
}
}
代码说明：
（1）dao：Data Access Object （数据访问对象）。
（2）JDBC 访问数据库的步骤:（八部曲、天龙八部）
1. 加载数据库驱动类
2. 获得数据库连接（打开水厂阀门）
3. 获得数据库操作句柄（打开小区阀门）
4. 获得结果集（打开家里阀门）
5. 处理结果集（做事）
6. 关闭结果集（关闭家里阀门）
7. 关闭操作句柄（关闭小区阀门）
8. 关闭数据库连接（关闭水厂阀门）
（3）第40行，在写完sql语句后，后面记得空一格。第41行，在开始写sql语句的时候，引号内记得先空一格再开始写。这样做是为了防止两个句子连接的时候出错。
4.测试dao类，对Dept表进行操作。
package com.lxd.test;
import java.util.List;
import org.junit.Before;
import org.junit.Test;
import com.newer.dao.DeptDao;
import com.newer.pojo.Dept;
/**
*
* @author XiangdongLee
*
*/
public class DeptDaoTest {
private DeptDao dao;
// @Before注解：在所有@Test测试方法之前首先运行init()方法。作用：初始化资源
@Before
public void init() {
// System.out.println("init");
dao = new DeptDao();
}
@Test
public void find() {
for (Dept dept : dao.find()) {
System.out.println(dept.getDeptno() + " " + dept.getDname() + " "
+ dept.getLoc());
}
}
// 也可以拆开写成如下形式：
// List<Dept> depts = dao.find();
// for (Dept dept : depts) {
// System.out.println(dept.getDeptno() + " " + dept.getDname() + " "
// + dept.getLoc());
// }
// }
@Test
public void add() {
Dept dept = new Dept();
dept.setDeptno(52);
dept.setDname("IT");
dept.setLoc("cs");
int count = dao.add(dept);
if (count > 0) {
System.out.println("新增成功.");
} else {
System.err.println("新增失败.");
}
}
@Test
public void modify() {
Dept dept = new Dept();
dept.setDeptno(50); // 该部门必须已存在
dept.setDname("Java");
dept.setLoc("sh");
int count = dao.modify(dept);
if (count > 0) {
System.out.println("修改成功.");
} else {
System.err.println("修改失败.");
}
}
@Test
public void remove() {
Dept dept = new Dept();
dept.setDeptno(50); // 该部门必须已存在
int count = dao.remove(dept.getDeptno());
if (count > 0) {
System.out.println("删除成功.");
} else {
System.err.println("删除失败.");
}
}
}
分享到：
相关推荐
Java使用Jdbc连接Oracle执行简单查询操作示例 Java使用Jdbc连接Oracle执行简单查询操作，是指使用Java语言通过Jdbc（Java Database Connectivity）连接Oracle数据库并执行简单查询操作的过程。本文将通过实例形式...
本话题主要关注如何使用J2EE技术与Oracle数据库进行交互，特别是针对"Dept"和"Emp"这两个表进行增删改查（CRUD）操作。 首先，Oracle数据库是全球广泛使用的数据库管理系统，尤其在企业级应用中，其稳定性和性能...
`JdbcTemplate`是Spring提供的工具类，用于简化JDBC操作，例如执行SQL和处理结果集。`RowMapper`接口用于将结果集映射到Java对象。 集成Spring Data JDBC可以减少代码量，提高可维护性，并且由于Spring的其他模块...
### JDBC操作数据库汇总 #### 一、SQL语言回顾 在进行JDBC操作之前，了解基本的SQL语言是非常重要的。下面是一些常用的SQL语句及其简要说明： 1. **Select** - 查询数据 ```sql SELECT * FROM T WHERE ... ```...
在本文中，我们将详细解释JDBC（Java Database Connectivity）的核心代码，涵盖了JDBC的基本概念、步骤、语句和实践操作。 JDBC概述 JDBC是Java语言中用于连接数据库的API（Application Programming Interface），...
Spring框架提供了一种强大的机制来简化Java应用程序中的数据库访问操作，这一机制即为Spring JDBC模块。通过Spring JDBC，开发者能够更加高效地管理与数据库的交互，减少传统JDBC编程中常见的一些繁琐且易出错的工作...
在Servlet网页版的环境中，我们可以利用Java的Servlet技术来实现对这个`dept`表的数据进行增、删、改、查操作。Servlet是一种Java服务器端编程技术，它可以接收并响应HTTP请求，为Web应用程序提供动态内容。 首先，...
PreparedStatement ps = conn.prepareStatement("INSERT INTO dept2 VALUES (?, ?, ?)"); ps.setInt(1, deptno); ps.setString(2, dname); ps.setString(3, loc); ps.execute(); ``` 2. **调用存储过程**： ...
- 通过`INNER JOIN`将`s_emp`表与`s_dept`表连接起来，连接条件是两表中的`dept_id`相等。 - 使用`WHERE`子句过滤出部门名为"Operations"的员工。 - 最后，使用`ORDER BY`子句按员工ID进行排序。 2. **ROWNUM与...
为了能够通过Java程序操作Oracle数据库，需要将Oracle的JDBC驱动添加到项目的类路径中。具体步骤如下： 1. **获取JDBC驱动包**：通常情况下，Oracle的JDBC驱动位于安装目录下的`jdbc/lib`文件夹中，例如`C:\oracle\...
在封装SQL语句之前，我们得知道什么是DAO封装与实体类以及JDBC工具类的封装与连接数据库的具体流程。...封装Dept表操作细节：DeptDao 3) DAO类所在包命名规则：公司网站域名.dao , 比如 com.bjpowernode.dao
另一个例子展示了如何接收一个ResultSet OUT参数，并将DEPT表的数据填充到这个ResultSet中： ```java public static void getDepartments(ResultSet[] rout) { // 获取默认连接 Connection conn = new Oracle...
通过以上内容的学习，初学者可以掌握 SQL 数据库的基础操作，包括创建数据库、数据表，执行增删改查操作以及简单的多表查询。同时，也介绍了如何使用 Java 语言通过 JDBC 接口与数据库进行交互，为后续开发应用打下...
在Java编程中，连接MySQL数据库是一项基础且...在实际项目中，这些基本操作通常会被封装到更高级别的数据访问组件或框架中，如JDBC模板（JdbcTemplate）、MyBatis或Hibernate等，以提供更简洁和安全的数据库访问方式。
在上述代码中，我们通过JOIN操作连接了Emp和Dept两个表，根据它们之间的外键关联（emp.dept_id = dept.id）获取员工及其所在部门的信息。执行查询后，遍历结果集并打印数据。 此外，为了遵循最佳实践，应考虑使用预...
在这个"struts2增删改查"项目中，开发者利用Struts2框架实现了对Oracle数据库中Emp和Dept两个表的数据操作，包括添加（Add）、删除（Delete）、修改（Update）和查询（Query）功能。以下是对这个项目涉及的关键知识...
- **编写 SQL 查询:** 在 Query 设计器中编写 SQL 查询语句，例如查询 `scott` 用户下的 `DEPT` 表。 **3. 添加报表元素:** - **拖放字段:** 将查询结果中的字段拖放到 Detail 部分，自动生成列头。 - **添加静态...
开发者可能使用了JDBC（Java Database Connectivity）API来连接和操作数据库，比如使用`Connection`、`Statement`或`PreparedStatement`对象执行SQL语句。 6. **MVC模式** 虽然这个项目是简单的示例，但可以借鉴...
##### 步骤2：将Oracle表数据导入到HDFS 接下来使用`sqoop import`命令将Oracle数据库中的表`HADOOP_EVENT_INFO`导入到HDFS中，并同时导入到Hive表中。 ```bash sqoop import --connect jdbc:oracle:thin:@192.168....
`执行了一个简单的`SELECT`语句，用于从`tb_dept`表中获取所有数据。 - **输出结果**：通过循环遍历`ResultSet`对象，打印出每一行的前两列数据。 综上所述，这段代码展示了如何使用Java中的JDBC API来连接SQL ...