58网站建设58xiamen,wordpress v5.2.2安装,做APP必须要有网站么,长沙做营销型网站公司一 概述
1 持久化概述 持久化(persistence): 把内存中的数据保存到可掉电式存储设备 (硬盘、U盘等) 中以供之后使用。 数据持久化是将数据保存到各种关系数据库#xff0c; 而在 Java中#xff0c;数据库存取技术只能通过 jdbc 来访问数据库。jdbc 是 Java 语言访问数据…一 概述
1 持久化概述 持久化(persistence): 把内存中的数据保存到可掉电式存储设备 (硬盘、U盘等) 中以供之后使用。 数据持久化是将数据保存到各种关系数据库 而在 Java中数据库存取技术只能通过 jdbc 来访问数据库。jdbc 是 Java 语言访问数据库的基石,其他技术都是对 jdbc 的封装.
2 JDBC 概述 JDBCJava DataBase Connectivity Java 数据库连接是一种用于执行 SQL 语句的 Java API可以为多种关系型数据库提供统一访问它由一组用 Java 语言编写的类和接口组成。 其实就是Java 官方提供的一套规范(接口)帮助开发人员快速实现不同关系型数据库的连接。
二 使用的功能类
1 DriverManager 类 DriverManager驱动管理对象主要用于加载注册关系型数据库的 Driver 类以及获取和关系型数据库的连接对象 ① 加载注册驱动
// 语法注册给定的驱动对象
static void registerDriver(Driver driver);// 在 com.mysql.jdbc.Driver 类中存在静态代码块把 com.mysql.jdbc.Driver 这一份字节码加载进 JVM
// 字节码被加载进JVM,就会执行其静态代码块.而其底层的静态代码块在完成注册驱动工作将驱动注册到DriverManger 中
static {try {DriverManager.registerDriver(new Driver());} catch (SQLException var1) {throw new RuntimeException(Cant register driver!);}
}// 加载注册驱动
Class.forName(com.mysql.jdbc.Driver);Java6 开始,JDBC4.0 无需加载注册驱动在 jar 包中存在一个java.sql.Driver 配置文件。此文件已经包含 com.mysql.jdbc.Driver 驱动名称。 程序会自动从 META-INF/services/java.sql.Driver 去读取当前的驱动类的全限定名,故不写加载注册驱动也可以但 web 项目必须写加载注册驱动代码否则无法连接数据库
② 获取连接对象
// 语法获取连接对象
static Connection getConnection(String url,String username,String password);// 参数 url 指定连接某一个数据库的路径语法
urljdbc:mysql://localhost:3306/jdbcdemo// 若连接的是本机的 MySQL,并且端口是默认 3306 ,可以简写
urljdbc:mysql:///jdbcdemo// 连接数据库的账号
username
// 连接数据库的密码
password2 Connection 类 关系型数据库连接对象用于 Java 程序与数据库的通信连接
// 获取执行语句对象静态语句执行对象
Statement createStatement();
// 获取执行语句对象预编译语句执行对象
PreparedStatement prepareStatement(String sql);
// 释放资源关闭连接对象
void close();// 设置是否为自动提交事务setAutoCommitboolean默认值为true表示自动提交(每条SQL语句都是一个单独的事务)设置为false相当于开启事务
con.setAutoCommit(false) // 提交结束事务
commit()
// 回滚结束事务
rollback()3 Statement 类 静态SQL语句执行对象用于执行字符串的 SQL 语句
// 执行DML/DDL语句,返回值为DML受影响的行数,DDL则返回0参数为insert、update、delete、create语句
int executeUpdate(String sql);// 执行DQL语句,返回值为执行查询之后的结果数据,参数为select
ResuleSet executeQuery(String sql);// 释放资源 关闭Statement对象
void close();三 创建流程
1 创建数据库表
CREATE TABLE t_employee (id bigint(20) NOT NULL AUTO_INCREMENT,eid varchar(10) NOT NULL,ename varchar(6) NOT NULL,job varchar(10) DEFAULT NULL,salary int(10) DEFAULT NULL,PRIMARY KEY (id),UNIQUE KEY eid (eid)
) ENGINEInnoDB AUTO_INCREMENT3 DEFAULT CHARSETutf8;2 增加一条员工信息
public class Test {// 增加一条员工信息public static void main(String[] args) throws ClassNotFoundException, SQLException {//1.加载jdbc注册驱动com.mysql.jdbc.Driver//反射加载类的字节码对象目的是实例化Driver对象底层调用newInstance()方法 需要目标类中包含无参构造Class.forName(com.mysql.jdbc.Driver);//2.获取数据库连接对象//Connection建立java代码和mysql数据库之间的连接关系/** jdbc:mysql:// 协议 表示使用jdbc技术连接mysql数据库* localhost:3306/ 本机回环地址 localhost127.0.0.1* 3306mysql默认的端口号* localhost:3306当连接本机默认mysql可以省略* 192.168.1.23:3307链接他人数据库的格式* jdbcdemo 需要连接的目标数据库名称* root mysql登录账号* root mysql登录密码* */Connection connection DriverManager.getConnection(jdbc:mysql://localhost:3306/web_crud,root,root);//3.创建执行sql语句的对象Statement最终执行sql语句的操作者Statement statement connection.createStatement();//4.执行目标的sql语句/** Statement对象提供了数据库表数据的CRUD操作的方法API* 增删改executeUpdate()* 查询executeQuery()* *///双引号嵌套通常会将包含的引号加转译字符或者使用单引号//String sql INSERT INTO t_employee(eid,ename,job,salary) VALUES(\tj008\,\大黄\,\医药代表\,15000);//单引号不转义String sql INSERT INTO t_employee(eid,ename,job,salary) VALUES(tj006,大黄,医药代表,15000);int row statement.executeUpdate(sql);//5.关闭对象释放资源statement.close();connection.close();}
}四 Dao组件
1 概述 DAO(Data Access Object) 数据访问对象即面向对象的数据库接口将所有对数据源数据库的访问操作抽象封装在一个公共 API 中实现增删改查
2 方法设计 ① 对数据库数据进行修改时,调用者需要传递多个参数进来,把这些数据存入数据库 ② 对数据库数据进行查询时,结果集的每行数据有多个列的值,把这些数据返回给调用者 ③ 需传递多个数据时,使用 JavaBean 对其进行封装
// 调用者将保存的数据封装到employee对象中,传递进来
void save(Employee ep);
// 通过id进行查询后,将每行数据封装到employee对象中,返回给调用者
Student selectOne(long id);3 步骤 ① 创建项目,导入数据库驱动包 ② 创建表和实体类包以及实体对象 (domain/Employee) ③ 创建 DAO 包和 DAO 接口,设计 DAO 接口方法 (dao/IEmployeeDAO) ④ 创建 DAO 实现包实现 DAO 接口(dao.impl/EmployeeDAOImpl) ⑤ 创建测试目录生成测试类和方法(test/EmployeeDAOTest) ⑥ 书写实现实现一个方法测试一个方法并且测试通过
4 演示
实体类
Data
NoArgsConstructor
AllArgsConstructor
public class Employee {private Long id;private String ename;private String job;private String eid;private Integer salary;
}接口
public interface IEmployeeDao {//修改员工public void updateEmployee(Employee employee);//增加员工public void addEmployee(Employee employee);
}实现类 – 执行 SQL 需要的参数是调用者传递进来的,故需要将其拼接到 SQL 里面
public class EmployeeDaoImpl implements IEmployeeDao {/*修改员工*/Overridepublic void updateEmployee(Employee employee) {try {Class.forName(com.mysql.jdbc.Driver);Connection connection DriverManager.getConnection(jdbc:mysql://localhost:3306/web_crud,root,root);Statement statement connection.createStatement();String sqlupdate t_employee set enameemployee.getEname() ,jobemployee.getJob(),eidemployee.getEid(),salaryemployee.getSalary() WHERE idemployee.getId();System.out.println(sql);int row statement.executeUpdate(sql);statement.close();connection.close();} catch (Exception e) {e.printStackTrace();}}/*增加员工*/Overridepublic void addEmployee(Employee employee) {try {Class.forName(com.mysql.jdbc.Driver);Connection connection DriverManager.getConnection(jdbc:mysql://localhost:3306/web_crud,root,root);Statement statement connection.createStatement();String sqlinsert into t_employee(ename,job,eid,salary)values(employee.getEname(),employee.getJob(),employee.getEid(),employee.getSalary());System.out.println(sql);int row statement.executeUpdate(sql);statement.close();connection.close();} catch (Exception e) {e.printStackTrace();}}
}测试类
public class EmployeeTest {/*修改员工信息*/Testpublic void employee_update(){// 创建dao对象IEmployeeDao employeeDaonew EmployeeDaoImpl();// 修改1号员工信息employeeDao.updateEmployee(new Employee(1L,大黄,保安,tj028,15000));}/*增加员工信息*/Testpublic void employee_add() {IEmployeeDao employeeDaonew EmployeeDaoImpl();employeeDao.addEmployee(new Employee(null,大黄,保安,tj027,15000));}
}五 预编译对象
1 作用 PreparedStatement 接口: 是 Statement 接口的子接口, 享有 Statement 中的方法预编译语句对象的sql 语句中使用 ? 来作为值的占位符从而解决拼接sql字符串易出错的问题
2 优化代码
实体类
Data
NoArgsConstructor
AllArgsConstructor
public class Employee {private Long id;private String ename;private String job;private String eid;private Integer salary;
}接口
public interface IEmployeeDao {//修改员工public void updateEmployee(Employee employee);//增加员工public void addEmployee(Employee employee);//根据id查询员工public Employee queryById(int id);//查询所有public ListEmployee queryALl();
}实现类
public class EmployeeDaoImpl implements IEmployeeDao {/*修改员工*/Overridepublic void updateEmployee(Employee employee) {try {Class.forName(com.mysql.jdbc.Driver);Connection connection DriverManager.getConnection(jdbc:mysql:///web_crud,root,root);String sqlupdate t_employee set eid? ,ename? ,job?,salary? WHERE id?;PreparedStatement statement connection.prepareStatement(sql);statement.setObject(1,employee.getEid());statement.setObject(2,employee.getEname());statement.setObject(3,employee.getJob());statement.setObject(4,employee.getSalary());statement.setObject(5,employee.getId());statement.executeUpdate();statement.close();connection.close();} catch (Exception e) {e.printStackTrace();}}/*增加员工*/Overridepublic void addEmployee(Employee employee) {try {Class.forName(com.mysql.jdbc.Driver);Connection connection DriverManager.getConnection(jdbc:mysql:///web_crud,root,root);//创建预编译对象:sql执行对象//编译sql的时候使用占位符替换语句中的未知的变量值String sqlinsert into t_employee(eid,ename,job,salary)values(?,?,?,?);PreparedStatement statement connection.prepareStatement(sql);/*执行CRUD操作前需通过set方法将预编译的占位符替换成客户端传入的具体值*//*statement.setString(1,employee.getEid());statement.setInt(2,employee.getEname());statement.setString(3,employee.getJob());statement.setString(4,employee.getSalary());*/// 顺序与占位符顺序一致(字段类型也一致)使用setObject可不考虑字段类型statement.setObject(1,employee.getEid());statement.setObject(2,employee.getEname());statement.setObject(3,employee.getJob());statement.setObject(4,employee.getSalary());//执行增加操作 此时需要知道占位符的值是什么statement.executeUpdate();statement.close();connection.close();} catch (Exception e) {e.printStackTrace();}}/*根据id查询*/Overridepublic Employee queryById(int id) {try {Class.forName(com.mysql.jdbc.Driver);Connection connection DriverManager.getConnection(jdbc:mysql:///web_crud,root,root);String sqlSELECT * from t_employee WHERE id?;PreparedStatement statement connection.prepareStatement(sql);statement.setObject(1,id);//执行查询将查询的员工信息封装在返回结果集对象中ResultSet resultSet statement.executeQuery();//遍历集合Employee employeenull;while (resultSet.next()){//当遍历的集合中有数据就获取里面的信息//循环依次获取数据库表的一行数据//获取字段信息Long tid resultSet.getLong(id);String eid resultSet.getString(eid);String ename resultSet.getString(ename);String job resultSet.getString(job);int salary resultSet.getInt(salary);//创建员工对象:使用有参构造实例化对象employeenew Employee(tid,eid,ename,job,salary);}statement.close();connection.close();resultSet.close();//返回员工对象return employee;} catch (Exception e) {e.printStackTrace();}return null;}//查询所有Overridepublic ListEmployee queryALl() {try {Class.forName(com.mysql.jdbc.Driver);Connection connection DriverManager.getConnection(jdbc:mysql:///web_crud,root,root);String sqlSELECT * from t_employee;PreparedStatement statement connection.prepareStatement(sql);ResultSet resultSet statement.executeQuery();//创建返回的集合对象ListEmployee listnew ArrayList();//遍历结果对象while (resultSet.next()){//获取每个员工表数据的列字段信息Long tid resultSet.getLong(id);String eid resultSet.getString(eid);String ename resultSet.getString(ename);String job resultSet.getString(job);int salary resultSet.getInt(salary);//将获取的数据封装到员工对象Employee employeenew Employee(tid,eid,ename,job,salary);//将员工对象添加到集合中list.add(employee);}statement.close();connection.close();resultSet.close();return list;} catch (Exception e) {e.printStackTrace();}return null;}
}测试类
public class EmployeeTest {//创建dao对象private IEmployeeDao employeeDaonew EmployeeDaoImpl();/*修改员工信息*/Testpublic void employee_update(){employeeDao.updateEmployee(new Employee(2L,小花,BA,tj035,9000));}/*增加员工信息*/Testpublic void employee_add() {employeeDao.addEmployee(new Employee(null,大黄,BA,tj036,9000));}/*根据id查询员工*/Testpublic void employee_listOne() {Employee employee employeeDao.queryById(1);System.out.println(employee);}/*查询所有*/Testpublic void employee_listAll() {employeeDao.queryALl().forEach(System.out::println);ListEmployee list employeeDao.queryALl();for (Employee employee : list) {System.out.println(employee);}}
}
