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语句为
UPDATE test SET sex = '女' WHERE id = 1

六.查找表数据

表数据的查找须要比上边的插入、删除操做多关闭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();

---

七.所有代码

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();

        }

    }
}