欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

三大范式&JDBC

程序员文章站 2022-05-30 09:47:35
...

数据库备份

  • 保证重要的数据不丢失
  • 数据转移 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);
        }
    }
}
相关标签: mysql java