三大范式&JDBC

数据库备份

• 保证重要的数据不丢失
• 数据转移 A----->B

MySQL数据库备份的方式

• 直接拷贝物理文件
• 在可视化工具中手动导出
• 使用命令行导出 mysqldump 命令行使用

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-P95JaFmO-1624882389045)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210624194104047.png)]

导入

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-tSZ28yym-1624882389046)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210624194633824.png)]

假设需要备份数据库,防止数据丢失;

把数据库传给别人!SQL文件给对方即可;

数据库设计

当数据库比较复杂的时候,我们就需要设计数据库

糟糕的数据库设计:

• 数据冗余,浪费空间
• 数据插入和删除都会很麻烦,会产生异常
• 程序性能变差

良好的数据库设计:

• 节省内存空间
• 保证数据库的完整性
• 屏蔽使用物理外键
• 方便我们开发系统

软件开发中,关于数据库的设计

• 分析需求:分析业务和需要处理的数据库的需求
• 概要设计:设计关系图 E-R 图

设计数据库的步骤: 比如个人博客

• 收集信息,分析需求
  • 用户表(用户登录注销,用户的个人信息,写博客,创建分类)
  • 分类表(文章分类,谁创建的)
  • 文章表(文章的信息)
  • 评论表
  • 友情链接表(链接信息)
  • 自定义表(系统信息,某个关键的字,或者一些主题) key:valeu
  • 说说表(发表心情…id…content…creat_time)
• 标识实体(把需求落地到每个字段)
• 标识实体之间的关系
  • 写博客:user–>blog
  • 创建分类:user–>category
  • 关注:user–>user
  • 友链:links
  • 评论表:user-user-blog

三大范式

为什么需要数据规范化

• 导致信息重复
• 更新异常
• 插入异常
  • 无法正常显示信息
• 删除异常
  • 丢失一些有效的信息

三大范式 关系型数据库设计

第一范式(1NF)

要求数据库表的每一列都是不可分割的原子数据项

原子性:保证每一列不可再分

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-zUxLZMap-1624882389047)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210627134100617.png)]

第二范式(2NF)

前提:满足第一范式

确保数据库表的每一列都和主键相关,而不能只与主键的某一部分相关(主要针对联合主键而言)

就是说每一张表只描述一件事情

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-g7PpPRSk-1624882389047)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210627134513908.png)]

第三范式(3NF)

前提:满足第二范式

确保数据表中的每一列都和主键直接相关,二不能间接相关

消除传递依赖

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-FjIxf8lF-1624882389048)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210627135016587.png)]

三大范式的意义在于,规范数据库的设计

规范性和性能的问题

阿里规范:关联查询的表不得超过三张表

• 考虑商业化的需求和目标(成本,用户体验!) 数据库的性能更加重要
• 在规范性能的问题的时候,需要适当的考虑一下规范性
• 有时候会故意给某些表增加一些冗余的字段(从多表查询中,变为单表查询),方便查询
• 故意增加一些计算列(从操作大数据量降低为小数据量的查询)

JDBC(重点)

什么是JDBC(Java怎么操作数据库)?

数据库驱动

驱动:声卡,显卡,数据库

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-E83WfL5v-1624882389049)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210627141137913.png)]

JDBC

SUN公司为了简化开发人员的操作(对不同数据库的操作),为了统一操作数据库,提供了一个规范JDBC

Java操作数据库的规范;

这些规范的具体实现有具体的厂商去做,开发人员只需要去学习这套规范就行了(JDBC接口);

架构里面:没有什么是加一层解决不了的

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-mX5FTPtx-1624882389050)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210627141554485.png)]

两个包:java.sql javax.sql

还需要导入一个数据库驱动包: mysql-connector-java

数据源的包后面也会用:c3p0 commons-dbcp commons-pool mchange-commons-java

第一个JDBC程序

创建测试数据库

CREATE DATABASE jdbcStudy CHARACTER SET utf8 COLLATE utf8_general_ci;

USE jdbcStudy;

CREATE TABLE users(
	id INT PRIMARY KEY,
	NAME VARCHAR(40),
	password VARCHAR(40),
	email VARCHAR(60),
	birthday DATE
);

INSERT INTO users(id,NAME,PASSWORD,email,birthday)
VALUES(1,'zhansan','123456','[email protected]','1980-12-04'),
(2,'lisi','123456','[email protected]','1981-12-04'),
(3,'wangwu','123456','[email protected]','1979-12-04');

创建一个普通项目

导入数据库驱动

创建一个lib目录,导包,

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-2LL5SRRT-1624882389050)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210627145819830.png)]

编写测试代码

import java.sql.*;

//我的第一个JDBC程序
public class JdbcFirstDemo {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //加载驱动
        //DriverManager.registerDriver(new Driver());  原来的写法,注册驱动,但是这样写会注册两次
        Class.forName("com.mysql.jdbc.Driver");//固定写法,加载驱动
        //连接信息 用户信息和URL
        String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true";
        String username="root";
        String password="root";
        //连接成功,返回数据库对象 connection 这个就代表数据库对象
        Connection connection = DriverManager.getConnection(url, username, password);
        //执行SQL的对象 statement
        Statement statement = connection.createStatement();
        //执行SQL的对象去执行SQL,可能存在结果,查看返回结果
        String sql ="SELECT * FROM users";
        ResultSet resultSet = statement.executeQuery(sql); //返回的结果集  是一个链表的形式 封装了我们全部的查询结果
        while(resultSet.next()){
            System.out.println("id=" + resultSet.getObject("id"));
            System.out.println("name=" + resultSet.getObject("NAME"));
            System.out.println("pwd=" + resultSet.getObject("PASSWORD"));
            System.out.println("email=" + resultSet.getObject("email"));
            System.out.println("birth=" + resultSet.getObject("birthday"));
            System.out.println("---------------------------------");
        }
        //释放连接
        resultSet.close();
        statement.close();
        connection.close();
    }
}

步骤

• 加载驱动 Class.forName(“com.mysql.jdbc.Driver”)
• 连接数据库 DriverManager
• 获得执行sql的对象 Statement
• 获得返回的结果集
• 释放连接

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-VigENKh7-1624882389051)(C:\Users\hang.li\AppData\Roaming\Typora\typora-user-images\image-20210627175943782.png)]

DriverManager

DriverManager.registerDriver(new Driver()); //原来的写法,注册驱动,但是这样写会注册两次
Class.forName("com.mysql.jdbc.Driver");//固定写法,加载驱动,推荐使用

//connection 代表数据库,做数据库级别的事情
//设置自动提交
//事务回滚
Connection connection = DriverManager.getConnection(url, username, password);

URL

  String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true";
// jdbc:mysql://主机地址:端口号/数据库名?参数1&参数2&参数3
// MySQL端口号默认是3306
// Oralce端口号默认1521
//jdbc:oralce:thin:@localhost:1521:sid

Statement 执行SQL的对象 PrepareStatement 也是执行SQL的对象

String sql ="SELECT * FROM users";

statement.executeQuery(); //查询操作返回  ResultSet
statement.execute(); //可以执行任何SQL
statement.executeUpdate(); // 更新,插入,删除,都可以用这个,返回受影响的行数(SQL匹配到的行数)

ResultSet 查询的结果集:封装了所有的查询结果

获得指定的数据类型

resuktSet.getObject();  //在不知道列类型的情况下使用
//如果知道列的类型就使用指定的类型
resultSet.getInt();
resultSet.getDate();
resultSet.getFloat();

遍历,指针

Statement对象

Jdbc中statement对象用于向数据库发送SQL语句,想完成对数据库的增删改查,只需通过这个对象向数据库发送增删改查语句即可;

statement对象的executeUpdate方法,用于向数据库发送增,珊,改,查的sql语句,executeUpdate执行完成后,将会返回一个整数(即增删改查语句导致了数据库几行数据发生了变化)

Statement.executeQuery方法用于向数据库发送查询语句,executeQuery方法放回查询结果的ResultSet对象;

CRUD操作-create

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

Statement st = conn.createStatement();
String sql = "insert into user(...)values(...)";
int num = st.executeUpdate(sql);
if(num>0){
    System.out.println("插入成功");
}

CRUD操作-delete

使用executeUpdate(String sql)方法完成数据删除操作

Statement st = conn.createStatement();
String sql = "delete from user where id=1";
int num = st.executeUpdate(sql);
if(num>0){
    System.out.println("删除成功");
}

CRUD操作-update

使用xecuteUpdate(String sql)方法完成数据修改操作

Statement st = conn.createStatement();
String sql = "update user set name='' where name='' ";
int num = st.executeUpdate(sql);
if(num>0){
    System.out.println("修改成功");
}

CRUD操作-read

Statement st = conn.createStatement();
String sql = "select * from user where id = 1";
ResultSet rs = st.executeQuery(sql);
while(rs.next()){
    //根据获取列的数据类型,分别调用rs的相应方法映射到java对象中
}

代码实现

用Maven搭建项目

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.otwb</groupId>
    <artifactId>MavenMysqlJDBC</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.48</version>
        </dependency>
    </dependencies>
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

</project>

创建配置文件

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username=root
password=root

创建工具类

package demo2.utils;

import java.io.InputStream;
import java.net.URL;
import java.sql.*;
import java.util.Properties;

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 {
            //用Properties 类获取配置文件
            InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
            Properties properties = new Properties();
            properties.load(in);
            driver = properties.getProperty("driver");
            url = properties.getProperty("url");
            username = properties.getProperty("username");
            password = properties.getProperty("password");
            // 驱动只用加载一次
            Class.forName(driver);
            //in.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    //获取连接
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, username, password);
    }

    //释放连接资源
    public static void release(Connection conn, Statement st, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (st != null) {
            try {
                st.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
//        if (in != null) {
//            try {
//                in.close();
//            } catch (IOException e) {
//                e.printStackTrace();
//            }
//        }
    }
}

创建业务类

package demo2;

import demo2.utils.JdbcUtils;

import java.sql.*;

public class TestInsert {
    public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            //JdbcUtils jdbcUtils = new JdbcUtils();
            conn = JdbcUtils.getConnection();//获取数据库连接
            st = conn.createStatement();//获得SQL的执行对象
            String sql = "insert into users(id,`NAME`,`PASSWORD`,`email`,`birthday`)" +
                    "values(5,'leak','12345','[email protected]','2021-06-27')";
            int i = st.executeUpdate(sql);
            if (i > 0) {
                System.out.println("插入成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, null);
        }
    }
}