MySql教程

# Mysql JDBC

本文主要是介绍# Mysql JDBC,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

文章目录

  • Mysql JDBC
      • 一、什么是JDBC?
      • 二、第一个JDBC程序
        • 1、创建数据库
      • 2、idea连接数据库
        • 3、封装JDBC连接数据库
        • 4、JDBC增、删、改、查
          • 增加记录
          • 删除记录
          • 修改记录
          • 查询记录

Mysql JDBC

一、什么是JDBC?

  • JDBC(Java Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API
    可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。是Java访问数据库的标准规范
  • JDBC提供了一种基准,据此可以构建更高级的工具和接口,使数据库开发人员能够编写数据库应用程序。
  • JDBC需要连接驱动,驱动是两个设备要进行通信,满足一定通信数据格式,数据格式由设备提供商规定,设备提供商为设备提供驱动软件,通过软件可以与该设备进行通信。
  • 我们使用的是mysql的驱动mysql jar包
  • 为了简化、统一对数据库的操作,定义了一套Java操作数据库的规范(接口),称之为JDBC。这套接口由数据库厂商去实现,这样,开发人员只需要学习jdbc接口,并通过jdbc加载具体的驱动,就可以操作数据库。

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

二、第一个JDBC程序

1、创建数据库

CREATE DATABASE jdbcStudy CHARACTER SET utf8 COLLATE utf8_general_ci;

USE jdbcStudy;

CREATE TABLE `users`(
	id INT(4) not null,
	NAME VARCHAR(40),
	PASSWORD VARCHAR(40),
	email VARCHAR(60),
	birthday date,
	PRIMARY KEY (`id`)
);

INSERT INTO `users`(id,NAME,PASSWORD,email,birthday)
VALUES(1,'zhansan','123456','zs@sina.com','1980-12-04'),
(2,'lisi','123456','lisi@sina.com','1981-12-04'),
(3,'wangwu','123456','wangwu@sina.com','1979-12-04')

2、idea连接数据库

public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //1.加载驱动
        Class.forName("com.mysql.jdbc.Driver");
    
        //2.用户信息和url(useUnicode=true&characterEncoding=utf-8表示设置数据库编码为utf-8,useSSL=true表示安全连接)
        String url=("jdbc:mysql://localhost/jdbcstudy?useUnicode=true&characterEncoding=utf-8&useSSL=true");
        String username="root";
        String password="root";
    
        //3.连接成功,创建数据库对象,connection是数据库的对象,他可以完成很多数据库操作
        Connection connection = DriverManager.getConnection(url,username,password);
    	connection.rollback();		 //事务回滚
		connection.commit();		//事务提交
		connection,setAutoCommit	 //设置自动提交
    
        //4.执行SQL的对象 Statement 执行sql的对象;
        Statement statement = connection.createStatement();
    	statement.executeQuery();		//查询操作返回 ResultSet
    	statement.execute();			//执行任何sql
    	statement.executeUpdate			//执行更新、删除、修改操作,返回一个受影响的行数

        //5.执行sql语句,查看返回结果
        String sql ="select * from users";
        ResultSet resultSet = statement.executeQuery(sql);

        while(resultSet.next()){
            System.out.println("id="+resultSet.getObject("id"));//不知道数据类型时使用Object
            System.out.println("name="+resultSet.getString("NAME"));
            System.out.println("Pwd="+resultSet.getString("PASSWORD"));
            System.out.println("email="+resultSet.getString("email"));
            System.out.println("birth="+resultSet.getDate("birthday"));
        }
        //6.关闭连接,释放资源
        resultSet.close();
        statement.close();
        connection.close();
    }

3、封装JDBC连接数据库

  • 在项目下新建一个util包,然后建一个Jdbcutil类来封装数据库连接的代码
public class JdbcUtil {
    //获取数据库连接
    private String jdbcName=("com.mysql.jdbc.Driver");
    private String url =("jdbc:mysql://localhost/jdbcstudy?useUnicode=true&characterEnding=utf-8&useSSL=true");
    private String userName=("root");
    private String password=("root");

    public Connection getConnection(){
        Connection con =null;
        try {
            Class.forName(jdbcName);
            con= DriverManager.getConnection(url,userName,password);
            Statement statement = con.createStatement();
        } catch (SQLException | ClassNotFoundException e) {
            e.printStackTrace();
        }
        return con;

    }
    //释放资源
    public static void release(Connection con, Statement sta, ResultSet rs){
        if(rs!=null){
            try {
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(sta!=null){
            try {
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(con!=null){
            try {
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

}
  • 调用连接
public class JdbcTest {
    public static void main(String[] args) throws SQLException {
        ResultSet rs =null;
        Connection conn =null;
        Statement sta =null;
        JdbcUtil jdbcUtil = new JdbcUtil();
        conn= jdbcUtil.getConnection();
        Statement statement = conn.createStatement();
        String sql = "select * from users";
        rs= statement.executeQuery(sql);
        while (rs.next()){
            System.out.println(rs.getInt("id"));
        }
        jdbcUtil.release(conn,sta,rs);

    }
}

4、JDBC增、删、改、查

  • 增加记录
public class JdbcTest {
    public static void main(String[] args) {
        ResultSet rs =null;
        Connection conn =null;
        Statement sta =null;
        JdbcUtil jdbcUtil = new JdbcUtil();
        conn= jdbcUtil.getConnection();
        try {
            sta = conn.createStatement();
            String sql = "insert into `users` (`id`,`NAME`,`PASSWORD`,`email`,`birthday`)\n" +
                    "values(4,'李冲','23123123',concat(floor(rand()*100000),\"@qq.com\"),'2000-2-12')";
            int i = sta.executeUpdate(sql);
            if(i>0){
                System.out.println("插入成功!!");
            }

    } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            jdbcUtil.release(conn,sta,rs);
        }
    }}
  • 删除记录
public class JdbcDelete {
    public static void main(String[] args) {
        ResultSet rs =null;
        Connection conn =null;
        Statement sta =null;
        JdbcUtil jdbcUtil = new JdbcUtil();
        conn= jdbcUtil.getConnection();
        try {
            sta = conn.createStatement();
            String sql = "delete from users where `id`=4";
            int i = sta.executeUpdate(sql);
            if(i>0){
                System.out.println("删除成功!!");
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            jdbcUtil.release(conn,sta,rs);
        }
    }}
  • 修改记录
public class JdbcUpdate {
    public static void main(String[] args) {
        ResultSet rs =null;
        Connection conn =null;
        Statement sta =null;
        JdbcUtil jdbcUtil = new JdbcUtil();
        conn= jdbcUtil.getConnection();
        try {
            sta = conn.createStatement();
            String sql = "update users set `NAME`='lihaugn'  where id =3";
            int i = sta.executeUpdate(sql);
            if(i>0){
                System.out.println("更新成功!!");
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            jdbcUtil.release(conn,sta,rs);
        }
    }
}
  • 查询记录
public class JdbcSelect {
    public static void main(String[] args) {
        ResultSet rs =null;
        Connection conn =null;
        Statement sta =null;
        JdbcUtil jdbcUtil = new JdbcUtil();
        conn= jdbcUtil.getConnection();
        try {
            sta = conn.createStatement();
            String sql = "select * from users";
            rs = sta.executeQuery(sql);
            while(rs.next()){
                System.out.println("id="+rs.getInt("id"));
                System.out.println("name="+rs.getString("NAME"));
                System.out.println("email"+rs.getString("email"));
                System.out.println("birthday"+rs.getString("birthday"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            jdbcUtil.release(conn,sta,rs);
        }
    }
}
这篇关于# Mysql JDBC的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!