java连接数据库,实现增删改查操作

一.前言

写这个文章的原因是为了巩固自己连接数据库步骤

二.MySQL数据库连接

数据库连接步骤加载驱动程序,获取数据库连接对象

2.1驱动jar包

2.2代码

package cn.sg.xx.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class Main {
    public static void main(String[] args) throws SQLException, ClassNotFoundException {
        try {
            //数据库驱动参数
            String Driver = "com.mysql.cj.jdbc.Driver";//"com.mysql.jdbc.Driver"-->驱动地址已经过时
            //连接的URL,数据库名为test
            String URL = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC&characterEncoding=utf8";//后边的参数serverTimezone-->指定时区,characterEncoding-->编码格式
            //数据库用户名
            String Username = "root";
            //数据库密码
            String Password = "123";
            //加载MySQL驱动程序
            Class.forName(Driver);
            //与MySQL数据库创立连接
            Connection con = null;
            con = DriverManager.getConnection(URL, Username, Password);

        } catch (ClassNotFoundException e) {
            System.out.println("驱动程序没有找到!");
        } catch (SQLException e) {
            System.out.println("SQL异常!");
        }
    }
}

三.增加表数据

String sql = "INSERT INTO test(id,NAME,sex) VALUES(?,?,?);";

建议写成这种语法,指定插入的列,可以防止表字段修改后,程序报错

使用PreparedStatement 进行sql语句的装配,可以防止sql注入

3.1代码

package cn.sg.xx.test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class Main {
    public static void main(String[] args) {
        try {
            //数据库驱动参数
            String Driver = "com.mysql.cj.jdbc.Driver";//"com.mysql.jdbc.Driver"-->驱动地址已经过时
            //连接的URL,数据库名为test
            String URL = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC&characterEncoding=utf8";//后边的参数serverTimezone-->指定时区,characterEncoding-->编码格式
            //数据库用户名
            String Username = "root";
            //数据库密码
            String Password = "123";
            //加载MySQL驱动程序
            Class.forName(Driver);
            //与MySQL数据库创立连接
            Connection con = null;
            con = DriverManager.getConnection(URL, Username, Password);

            //sql语句装配,?为占位符
            String sql = "INSERT INTO test(id,NAME,sex) VALUES(?,?,?);";
            PreparedStatement stmt = con.prepareStatement(sql);
            stmt.setInt(1, 2);
            stmt.setString(2, "张三");
            stmt.setString(3, "男");
            stmt.executeUpdate();

            //执行完数据库的操作有指令之后要释放资源,否则会导致内存的溢出
            stmt.close();
            con.close();

        } catch (ClassNotFoundException e) {
            System.out.println("驱动程序没有找到!");
        } catch (SQLException e) {
            System.out.println("SQL异常!");
        }

    }
}

四.删除表数据

删除表数据的操作和插入操作基本相同,只有sql语句不同

4.1代码

String sql = "DELETE FROM test WHERE id = 1";
PreparedStatement stmt = con.prepareStatement(sql);
stmt.executeUpdate();

五.修改表数据

同插入数据一样,仅仅修改sql语句为

六.查找表数据

表数据的查找需要比上边的插入、删除操作多关闭ResoultSet资源

ResoultSet rs;

rs.close();

6.1代码

//查找表数据
            String sql = "SELECT * FROM test";
            PreparedStatement stmt = con.prepareStatement(sql);
            ResultSet rs = stmt.executeQuery();
            //从 rs 获取数据
            while (rs.next()) {
                //rs.getMetaData().getColumnCount() --> 获取表的列数
                for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) {
                    String colunmName = rs.getMetaData().getColumnName(i);//获取列名
                    Object temp = rs.getString(i);//获取该列对应元素的值
                    System.out.print(colunmName + "-->" + temp + "/t");
                }
                System.out.println();

java连接数据库,实现增删改查操作

七.全部代码

package cn.sg.xx.test;

import java.sql.*;

public class Main {
    public static void main(String[] args) throws SQLException {
        Connection con = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        try {
            //数据库驱动参数
            String Driver = "com.mysql.cj.jdbc.Driver";//"com.mysql.jdbc.Driver"-->驱动地址已经过时
            //连接的URL,数据库名为test
            String URL = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC&characterEncoding=utf8";//后边的参数serverTimezone-->指定时区,characterEncoding-->编码格式
            //数据库用户名
            String Username = "root";
            //数据库密码
            String Password = "123";
            //加载MySQL驱动程序
            Class.forName(Driver);
            //与MySQL数据库创立连接
            con = DriverManager.getConnection(URL, Username, Password);

            //sql语句装配,?为占位符
            String sql = "INSERT INTO test(id,NAME,sex) VALUES(?,?,?);";
            stmt = con.prepareStatement(sql);
            stmt.setInt(1, 2);
            stmt.setString(2, "张三");
            stmt.setString(3, "男");
            stmt.executeUpdate();

            //删除表数据
            sql = "DELETE FROM test WHERE id = 1";
            stmt = con.prepareStatement(sql);
            stmt.executeUpdate();

            //修改表数据
            sql = "UPDATE test SET sex = '女' WHERE id = 1";
            stmt = con.prepareStatement(sql);
            stmt.executeUpdate();

            //查找表数据
            sql = "SELECT * FROM test";
            stmt = con.prepareStatement(sql);
            rs = stmt.executeQuery();
            //从 rs 获取数据
            while (rs.next()) {
                //rs.getMetaData().getColumnCount() --> 获取表的列数
                for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) {
                    String colunmName = rs.getMetaData().getColumnName(i);//获取列名
                    Object temp = rs.getString(i);//获取该列对应元素的值
                    System.out.print(colunmName + "-->" + temp + "/t");
                }
                System.out.println();
            }
            //执行完数据库的操作有指令之后要释放资源,否则会导致内存的溢出

        } catch (ClassNotFoundException e) {
            System.out.println("驱动程序没有找到!");
        } catch (SQLException e) {
            System.out.println("SQL异常!");
        } finally {
            //关闭资源
            if (rs != null)
                rs.close();
            if (stmt != null)
                stmt.close();
            if (con != null)
                con.close();

        }

    }
}

原文 

https://segmentfault.com/a/1190000022503896

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » java连接数据库,实现增删改查操作

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址