0
点赞
收藏
分享

微信扫一扫

JDBC介绍 使用步骤 导包 代码优化 PreparedStatement 封装工具类

英乐 2022-02-17 阅读 51
intellij-ideajavamysql

1.1介绍
JDBC : Java DataBase Connectivity (java数据库链接)
就是让java连接到数据库的API
API : Application Programming Intergace (应用程序接口)
就是函数库
1.2JDBC 使用步骤
第0步：导包
第1步：注册驱动(仅仅只做一次)
第2步：建立连接（Connection）
第3步:创建运行SQL的语句对象(Statement)
第4步:运行语句
第5步:处理运行结果(ResultSet)
第6步:释放资源
其中 如果是添加，删除，更新操作可以没有第5步，查询肯定有第五步

2.0导包
在这里插入图片描述

创建java项目
创建lib文件夹
把mysql-connector-java-5.1.38-bin.jar复制到lib中
在这里插入图片描述Idea右上角，项目的结构化配置
在这里插入图片描述
添加自己拖动到lib包中的jar包
2.1实例

package main;


import java.sql.*;

public class Jdbc_01 {
    public static void main(String[]args) throws Exception {
        //第1步：注册驱动 (仅仅做一次)
        Class.forName("com.mysql.jdbc.Driver");
        //第2步：建立连接(Connection)
        Connection conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/-021-","root","1234");
        //第3步：创建运行SQL的语句对象(Statement)
        String sql = "select * from student";
        Statement stmt = conn.createStatement();
        //第4步，运行语句，接收数据库结果集
        ResultSet rs = stmt.executeQuery(sql);
        //第5步,运行处理结果
        while (rs.next()) {
            System.out.println("索引打印"+rs.getString(2));
            System.out.println("标签打印"+rs.getString("name"));

        }
        //第六步，释放资源
        rs.close();
        stmt.close();
        conn.close();
        }
}

2.2代码优化

package main;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

/**
 *
 * 优化关闭资源
 * @author Mr.Wang
 * @date 22-2-17
 */
public class Jdbc_02 {
    public static void main(String[] args) {
        ResultSet resultSet=null;
        Statement statement=null;
        Connection conn=null;
        try {
            //第1步：注册驱动 (仅仅做一次)
            Class.forName("com.mysql.jdbc.Driver");
            //第2步：建立连接(Connection)
            conn= DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/_21_","root","root");
            //第3步：创建运行SQL的语句对象(Statement)
            String sql="select * from student";
            statement=conn.createStatement();
            //第4步：运行语句,得到结果集
            resultSet = statement.executeQuery(sql);
            //第5步：处理运行结果(ResultSet)
            while(resultSet.next()){
                System.out.println("索引打印"+resultSet.getString(2));
                System.out.println("标签打印"+resultSet.getString("name"));;
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                //第6步：释放资源
                if(resultSet!=null){
                    resultSet.close();
                }
                if(statement!=null){
                    statement.close();
                }
                if(conn!=null){
                    conn.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }

        }

    }
}

2.3DML

package main;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

/**
 *
 * DML操作
 * @author Mr.Wang
 * @date 22-2-17
 */
public class Jdbc_03 {

    public static void main(String[] args) {
        ResultSet resultSet=null;
        Statement statement=null;
        Connection conn=null;
        try {
            //第1步：注册驱动 (仅仅做一次)
            Class.forName("com.mysql.jdbc.Driver");
            //第2步：建立连接(Connection)
            conn= DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/_21_","root","root");
            //第3步：创建运行SQL的语句对象(Statement)
            String sql="delete from student where id=9 ";
            statement=conn.createStatement();
            //第4步：运行语句,得到结果集
//            resultSet = statement.executeQuery(sql);
            int i= statement.executeUpdate(sql);
            System.out.println("影响了"+i+"条");
            //第5步：处理运行结果(ResultSet)
//            while(resultSet.next()){
//                System.out.println("索引打印"+resultSet.getString(2));
//                System.out.println("标签打印"+resultSet.getString("name"));;
//            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                //第6步：释放资源
                if(resultSet!=null){
                    resultSet.close();
                }
                if(statement!=null){
                    statement.close();
                }
                if(conn!=null){
                    conn.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }

        }
    }
}


package main;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

/**
 *
 * DML操作
 * @author Mr.Wang
 * @date 22-2-17
 */
public class Jdbc_03 {

    public static void main(String[] args) {
        ResultSet resultSet=null;
        Statement statement=null;
        Connection conn=null;
        try {
            //第1步：注册驱动 (仅仅做一次)
            Class.forName("com.mysql.jdbc.Driver");
            //第2步：建立连接(Connection)
            conn= DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/_21_","root","root");
            //第3步：创建运行SQL的语句对象(Statement)
            String sql="delete from student where id=9 ";
            statement=conn.createStatement();
            //第4步：运行语句,得到结果集
//            resultSet = statement.executeQuery(sql);
            int i= statement.executeUpdate(sql);
            System.out.println("影响了"+i+"条");
            //第5步：处理运行结果(ResultSet)
//            while(resultSet.next()){
//                System.out.println("索引打印"+resultSet.getString(2));
//                System.out.println("标签打印"+resultSet.getString("name"));;
//            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                //第6步：释放资源
                if(resultSet!=null){
                    resultSet.close();
                }
                if(statement!=null){
                    statement.close();
                }
                if(conn!=null){
                    conn.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }

        }
    }
}

2.4 PreparedStatement
区别
PreparedStatement是预编译的SQL语句对象,sql语句被预编译并保存在对象中, 被封装的sql语句中可以使用动态包含的参数 ? ,
在执行的时候,可以为?传递参数
Statement用于执行静态SQL语句,在执行的时候,必须指定一个事先准备好的SQL语句,并且相对不安全,会有SQL注入的风险
实例1使用PreparedStatement 执行查询

public static void load(int id) {

		Connection conn = null;
		PreparedStatement prst = null;
		ResultSet rs = null;
		try {
			// 1 加载驱动
			Class.forName("com.mysql.jdbc.Driver");
			// 2 创建数据库连接对象
			conn = DriverManager.getConnection(
					"jdbc:mysql://127.0.0.1:3306/_06_", "root", "root");

			// 这里我们用? 问号代替值,可以叫占位符,也可以叫通配符
			String sql = "select * from test_jdbc where id = ?";
			// 3 语句传输对象
			prst = conn.prepareStatement(sql);
			// 设置第一个?的值
			prst.setInt(1, id);
			rs = prst.executeQuery();
			while (rs.next()) {
				System.out.print(rs.getInt("id") + "   ");
				System.out.print(rs.getString("name") + "   ");
				System.out.println(rs.getString("money") + "   ");
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				// 关闭资源,从上到下依次关闭,后打开的先关闭
				if (rs != null) {
					rs.close();
				}
				if (prst != null) {
					prst.close();
				}
				if (conn != null) {
					conn.close();
				}
			} catch (Exception e2) {
				e2.printStackTrace();
			}
		}
	}

实例2使用PreparedStatement 执行增删改,以添加为例

public static void add(int id, String name, double money) {

		Connection conn = null;
		PreparedStatement prst = null;
		try {
			// 1 加载驱动
			Class.forName("com.mysql.jdbc.Driver");
			// 2 创建数据库连接对象
			conn = DriverManager.getConnection(
					"jdbc:mysql://127.0.0.1:3306/_06_", "root", "root");

			// 这里我们用? 问号代替值,可以叫占位符,也可以叫通配符
			String sql = "insert into test_jdbc (id,name,money) values (?,?,?)";
			// 3 语句传输对象
			prst = conn.prepareStatement(sql);
			// 设置第一个?的值
			prst.setInt(1, id);
			prst.setString(2, name);
			prst.setDouble(3, money);
			// 返回也是影响的条数
			int count = prst.executeUpdate();
			System.out.println("影响了 "+count+" 条数据");
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				// 关闭资源,从上到下依次关闭,后打开的先关闭
				if (prst != null) {
					prst.close();
				}
				if (conn != null) {
					conn.close();
				}
			} catch (Exception e2) {
				e2.printStackTrace();
			}
		}
	}

3.封装工具类

举报

相关推荐

Jdbc封装工具

bcjavasqlMySQL数据库

封装JDBC工具类

sql数据库

common-dbutils 简单封装工具类

sqlbcListJavaScript前端开发

封装 JDBC 工具类-普通版

sqljavamysql虚拟化云计算

Qt如何封装工具

linuxqtlibvlcGPU 硬解码

class方法封装工具库

javascript前端jquery

jdbc使用PreparedStatement调用SQL语句

sql数据库database

redis封装工具类（缓存穿透，缓存击穿（逻辑过期））Ⅰ

缓存redisjava

springboot整合redis，自定义redisTemplate，及封装工具类

redisspring bootjava

RabbitMQ安装配置，封装工具类，发送消息及监听

java-rabbitmqrabbitmqjava
0 条评论