• day09学习总结

    一、事务

    案例分析：

     概念：

            事务是最小的原子单元，不能再进行拆分 在执行一条或者多条SQL语句的时候 要么都成功，要么都失败

    事务的指令：

    指令描述
    select @@autocommit查询提交方式 默认为1自动提交   0为手动提交
    set @@autocommit设置事务的提交方式(0表示手动提交 1表示自动提交))
    start  transaction开启事务
    rollback回滚
    commit提交事务

    事务执行的原理：

    事务的四大原则：

            A 事务的原子性 事务是最小的原子单位 不能进行再拆分

            C 事务的一致性:事务执行sql语句 要么是同时执行成功 (成功状态) 要么同时执行失败(失败状态)

            I 事务隔离性:每一个事务都是相互隔离的 互不影响

            D事务持久性: 只要commit 提交之后 数据将永久保存到数据中

    二、视图

    概念：

            视图是指计算机数据库中的视图，是一个虚拟表，其内容由查询定义。同真实的表一样

    作用：

            简单性：

                    看到的就是需要的。视图不仅可以简化用户对数据的理解，也可以简化他们的操作。那些被经常使用 的查询可以被定 义为视图

            安全性：

                    通过视图用户只能查询和修改他们所能见到的数据。但不能授权到数据库特定行和特定的列上

    创建视图：

            语法：create view 视图名称  as  查询语句

                    CREATE VIEW v_acc AS SELECT aname FROM account

    查看视图：

            语法：select  *  from 视图名称

                    SELECT * FROM v_acc

    修改视图：

            语法：alter  view 视图名称  as 查询语句

                    ALTER VIEW v_acc AS SELECT aname,amoney FROM account

    删除视图：

            语法：drop view 视图名称

                    DROP VIEW v_acc

    三、DCL对用户的管理

    查看用户：

            切入mysql库

            查看用户表

    创建用户：

            语法：create user ‘用户名’@‘主机名’ identified by ‘密码’

                    CREATE USER 'lisi'@'localhost' IDENTIFIED BY '123'

    修改用户密码：

            语法：update user set password=password(新密码) where user=用户名

                    UPDATE USER SET PASSWORD =PASSWORD('456') WHERE USER='lisi'

    删除用户：

            语法：drop user ‘用户名’@‘主机名’

                    DROP USER 'lisi'@'localhost'

    注意点：

            A. mysql中的密码是使用MD5来进行加密

            B.md5加密方式不可逆(只能加密 不能解密) 同一个内容md5 加密都是一样的

            C.网站:https://www.cmd5.com/  

    四、客户端连接数据库

    缺点：

            在实际开发中 开发人员是使用客户端连接数据库 用户使用通过界面来(使用java代码来操作)操作数据 

    五、jdbc操作数据库

    简介：

            jdbc ==> java db connection 使用java来连接数据库 使用java代码来操作数据库

            jdbc是java代码操作数据库的桥梁 主要提供了一些类与接口 主要提供连接数据库的规范

       

    jdbc操作数据库的原理：

            

     

    mysql 驱动包：

    1.mysql-connector-java-5.xx-bin.jar ==>适用于mysql5的版本

    2.mysql-connector-java-8.xx-bin.jar ==>适用于mysql8的版本

    3.下载jar地址:https://mvnrepository.com/artifact/mysql/mysql-connectorjava/8.0.28 

    搭建基础：

            下载对应版本的驱动包jar包，添加到项目的lib目录下，添加依赖即可

    jdbc操作数据库流程：

            A.通过反射加载驱动

            B.获取连接对象

            C.根据连接对象获取执行sql的对象

            D.向数据库发送sql指令

            E.获取结果集

            F.关闭资源

    jdbc操作数据库的增删改：

    1. package com.qf.test.test01;
    2.  
    3. import java.sql.Connection;
    4. import java.sql.DriverManager;
    5. import java.sql.SQLException;
    6. import java.sql.Statement;
    7.  
    8. public class Test01 {
    9.     public static void main(String[] args) throws SQLException, ClassNotFoundException {
    10.         //通过反射加载驱动
    11.         Class.forName("com.mysql.cj.jdbc.Driver");
    12.         //获取连接对象
    13.         Connection root = DriverManager.getConnection("jdbc:mysql://localhost:3306/day09?characterEncoding=utf-8", 
    14.                 "root", "123456");
    15.         //获取发送指令对象
    16.         Statement sta = root.createStatement();
    17.         //编写sql语句
    18.         String sql = "insert into user(uname,upwd) values('李四','123456')";
    19.         //发送指令
    20.         int num = sta.executeUpdate(sql);
    21.         System.out.println(num);
    22.         //关闭资源
    23.         sta.close();
    24.         root.close();
    25.     }
    26.  
    27.  
    28. }

    jdbc API：

    常用方法：

     

    jdbc操作数据库的-查询：

            数据表与实体类的关系：

     

            ResultSet方法：

     

    1. package com.qf.test01;
    2. import java.sql.*;
    3.     public class Test03 {
    4.         public static void main(String[] args) throws SQLException,
    5.             ClassNotFoundException {
    6.                 //加载驱动
    7.                 Class.forName("com.mysql.jdbc.Driver");
    8.                 //获取连接对象
    9.                 Connection con =
    10.                     DriverManager.getConnection("jdbc:mysql://localhost:3306/day09?
    11.                     characterEncoding=utf-8", "root", "root");
    12.                 //获取执行sql对象
    13.                 Statement sta = con.createStatement();
    14.                 String sql ="select * from user ";
    15.                 //发送指令 获取结果集
    16.                 ResultSet rs = sta.executeQuery(sql);
    17.                 //使用循环获取数据
    18.                 while (rs.next()) {
    19.                     //根据索引获取
    20.                     // int uid = rs.getInt(1);
    21.                     // String uname = rs.getString(2);
    22.                     // String upwd = rs.getString(3);
    23.                     int uid = rs.getInt("uid");
    24.                     // String uname = rs.getString("uname");
    25.                     String upwd = rs.getString("upwd");
    26.                     System.out.println(uid+"\t"+"uname"+"\t"+upwd);
    27.                 }
    28.                 //关闭资源
    29.                 rs.close();
    30.                 sta.close();
    31.                 con.close();
    32.     }
    33. }

    案例： 登录验证

    需求：

     代码：

    1. package com.qf.test.test01;
    2.  
    3. import java.sql.*;
    4. import java.util.Scanner;
    5.  
    6. public class Test02 {
    7.     public static void main(String[] args) throws SQLException, ClassNotFoundException {
    8.         //实例化Scanner
    9.         Scanner input = new Scanner(System.in);
    10.         System.out.println("请输入用户名");
    11.         String user = input.next();
    12.         System.out.println("请输入密码");
    13.         String pwd = input.next();
    14.         if (show(user,pwd)){
    15.             System.out.println("登录成功");
    16.         }else {
    17.             System.out.println("登录失败");
    18.         }
    19.  
    20.     }
    21.  
    22.     public static boolean show(String user,String pwd) throws SQLException, ClassNotFoundException {
    23.         //加载驱动
    24.         Class.forName("com.mysql.cj.jdbc.Driver");
    25.         //获取连接对象
    26.         Connection root = DriverManager.getConnection("jdbc:mysql://localhost:3306/day09?characterEncoding=utf-8", "root", "123456");
    27.         //获取发送指令对象
    28.         Statement sta = root.createStatement();
    29.         //编写SQL语句
    30.         String sql = "select * from user where uname='"+user+"' and upwd='"+pwd+"'";
    31.         //获取结果集
    32.         ResultSet rs = sta.executeQuery(sql);
    33.         //判断
    34.         if (rs.next()){
    35.             return true;
    36.         }
    37.         return false;
    38.     }
    39. }

    六、PreparedStatement

    刚才的登录案例会出现的问题：

     

    PreparedStatement 与 Statement 比较：

            PreparedStatement 是Statement的子类

            PreparedStatement 会预编译 SQL语句  检测SQL语句是否正常

            PreparedStatement 可以防止SQL注入问题，执行率比较高

    PreparedStatement 常用方法：

    改造登录案例：

     

    1. package com.qf.test.test01;
    2.  
    3. import java.sql.*;
    4. import java.util.Scanner;
    5.  
    6. public class Test02 {
    7.     public static void main(String[] args) throws SQLException, ClassNotFoundException {
    8.         //实例化Scanner
    9.         Scanner input = new Scanner(System.in);
    10.         System.out.println("请输入用户名");
    11.         String user = input.next();
    12.         System.out.println("请输入密码");
    13.         String pwd = input.next();
    14.         if (show(user,pwd)){
    15.             System.out.println("登录成功");
    16.         }else {
    17.             System.out.println("登录失败");
    18.         }
    19.  
    20.     }
    21.  
    22.     public static boolean show(String user,String pwd) throws SQLException, ClassNotFoundException {
    23.         //加载驱动
    24.         Class.forName("com.mysql.cj.jdbc.Driver");
    25.         //获取连接对象
    26.         Connection root = DriverManager.getConnection("jdbc:mysql://localhost:3306/day09?characterEncoding=utf-8", "root", "123456");
    27.         String sql = "select * from user where uname=? and upwd=?";
    28.         PreparedStatement ps = root.prepareStatement(sql);
    29.         //给占位符设置值
    30.         ps.setString(1,user);
    31.         ps.setString(2,pwd);
    32.         //提交SQL语句
    33.         ResultSet rs = ps.executeQuery();
    34.         if (rs.next()){
    35.             return true;
    36.         }
    37.         return false;
    38.     }
    39. }

    七、数据库工具类封装

    分析：

     

    代码：

    BaseDao：

    1. package com.qf.test.test01;
    2.  
    3. import java.sql.*;
    4.  
    5. public class BaseDao {
    6.     private static final  String className="com.mysql.cj.jdbc.Driver";
    7.     private static final String driveUrl="jdbc:mysql://localhost:3306/day09?characterEncoding=utf-8";
    8.     private static final String userName = "root";
    9.     private static final String password="123456";
    10.  
    11.     //获取连接对象方法
    12.     public static Connection getConn(){
    13.         Connection conn = null;
    14.         try {
    15.             //通过反射加载驱动
    16.             Class.forName(className);
    17.             //获取连接对象
    18.             conn = DriverManager.getConnection(driveUrl, userName, password);
    19.         } catch (ClassNotFoundException e) {
    20.             e.printStackTrace();
    21.         } catch (SQLException e) {
    22.             e.printStackTrace();
    23.         }
    24.         return conn;
    25.     }
    26.  
    27.     //增删改方法
    28.     public static int update(String  sql,Object[] objects){
    29.         Connection conn=null;
    30.         PreparedStatement ps=null;
    31.         int num = -1;
    32.         try {
    33.             //获取连接对象
    34.             conn = getConn();
    35.             //执行SQL语句
    36.              ps= conn.prepareStatement(sql);
    37.             //判断数组非空
    38.             if (objects!=null&&objects.length>0){
    39.                 for (int i=0;i
    40.                     //给占位符赋值
    41.                     ps.setObject(i+1,objects[i]);
    42.                 }
    43.             }
    44.             //发送SQL语句
    45.             num = ps.executeUpdate();
    46.         } catch (SQLException e) {
    47.             e.printStackTrace();
    48.         }finally {
    49.             //关闭资源
    50.             close(null,ps,conn);
    51.         }
    52.  
    53.         return num;
    54.     }
    55.  
    56.     //查询方法
    57.     public static ResultSet getRs(String sql,Object [] objects){
    58.         ResultSet rs = null;
    59.         Connection conn=null;
    60.         PreparedStatement ps=null;
    61.         try {
    62.             //获取连接对象
    63.            conn = getConn();
    64.             //执行SQL语句
    65.              ps = conn.prepareStatement(sql);
    66.             //判断数组非空
    67.             if (objects!=null&&objects.length>0){
    68.                 for (int i=0;i
    69.                     //给占位符赋值
    70.                     ps.setObject(i+1,objects[i]);
    71.                 }
    72.             }
    73.             //发送SQL语句
    74.             rs = ps.executeQuery();
    75.         } catch (SQLException e) {
    76.             e.printStackTrace();
    77.         }
    78.         return rs;
    79.     }
    80.  
    81.     //关闭资源方法
    82.     public static   void close(ResultSet rs,PreparedStatement ps,Connection conn){
    83.         try {
    84.             if (rs!=null){
    85.                 rs.close();
    86.             }
    87.             if (ps!=null){
    88.                 ps.close();
    89.             }
    90.             if (conn!=null){
    91.                 conn.close();
    92.             }
    93.         } catch (SQLException e) {
    94.             e.printStackTrace();
    95.         }
    96.     }
    97. }

    测试类：

    1. package com.qf.test.test01;
    2.  
    3. import java.sql.ResultSet;
    4. import java.sql.SQLException;
    5.  
    6. public class Test03 {
    7.     public static void main(String[] args) throws SQLException {
    8.         //增
    9.         /*String sql = "insert into user(uname,upwd) values(?,?)";
    10.         Object [] objects={"王五","123456789"};
    11.         int num = BaseDao.update(sql, objects);
    12.         System.out.println(num);*/
    13.         //删
    14.        /* String sql ="delete from user where uid=6";
    15.         int num = BaseDao.update(sql, null);
    16.         System.out.println(num);*/
    17.        //改
    18.        /* String sql = "update user set uname=?,upwd=? where uid=?";
    19.         Object [] objects = {"班长","666","4"};
    20.         BaseDao.update(sql,objects);*/
    21.         //查
    22.         String sql = "select * from user";
    23.         ResultSet rs = BaseDao.getRs(sql, null);
    24.         //遍历结果集
    25.         while (rs.next()){
    26.             System.out.println(rs.getInt("uid"));
    27.             System.out.println(rs.getString("uname"));
    28.             System.out.println(rs.getString("upwd"));
    29.         }
    30.     }
    31. }

     

  • 相关阅读:
    Nebula Graph图数据库教程介绍
    2024年阿里云创建【幻兽帕鲁/Palworld】32人联机服务器教程
    Acwing.4736步行者（模拟）
    智能油烟机 优化烹饪体验
    运筹帷幄决胜千里，Python3.10原生协程asyncio工业级真实协程异步消费任务调度实践
    超全Chat GPT论文修改指令
    [AutoSAR系列] 1.2 AutoSar 综述
    Nginx反向代理
    <二>强弱指针使用场景之 多线程访问共享对象问题
    etcd之读性能主要影响因素
  • 原文地址：https://blog.csdn.net/qq_53884348/article/details/126585207