我的编程空间,编程开发者的网络收藏夹
学习永远不晚

JDBC 连接 MySQL

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

JDBC 连接 MySQL

哈喽~大家好,这次我们来看看 JDBC 如何 连接 MySQL.

目录

一、开头

二、介绍

1、JDBC 的概念

2、JDBC 的功能

3、JDBC 的常用接口和类

三、数据库的创建(MySQL)

1、连接 MySQL 

(1)、注册驱动

(2)、获取连接

(3)、获取执行者连接

(4)、执行 SQL 语句,并接受结果

(5)、处理结果

(6)、释放资源

四、对 MySQL 进行增删改查

1、准备工作

五、JDBC 实践操作

1、根据 id 获取信息

2、添加信息

3、修改信息

4、删除信息

六、代码优化

七、JSP 连接 MYSQL

1、查询操作

2、增加操作

3、修改操作

4、删除操作


       首先如何下载安装 MySQL (链接),如何下载安装 SQLyog (链接),以及怎样下载 mysql-connector-java.jar(链接),可以看看这三位大佬的,这里操作数据库用的是  SQLyog  这款软件。

       好了之后,我们用 idea 创建项目,记得要勾选 Web应用程序。

        然后将 mysql-connector-java.jar 放入在 WEB - INF 里面的 lib 里面(如果没有就自己创建一个,记得要打包文件)

1、JDBC 的概念

        JDBC 是 Java DataBase Connectivity (Java 数据连接)技术的简称,是一种可用于执行 SQL 语句的 Java API。它由一些 java 语言编写的类和接口组成;程序员通过使用 jdbc 可以方便地将 SQL 语句传送给几乎任何一种数据库

2、JDBC 的功能

(1) 与数据库建立连接。
(2) 向数据库发送 SQL 语句并执行这些语句。
(3) 处理数据返回的结果。

3、JDBC 的常用接口和类

(1) Driver 接口:加载驱动程序。
(2) DriverManager 类:装人所需的 JDBC 驱动程序,编程时调用它的方法来创建连接。
(3) Connection 接口:编程时使用该类对象创建 Statement 对象。
(4) Statement 接口:编程时使用该类对象得到 ResultSet 对象。
(5) ResultSet 类:负责保存 Statement 执行后所产生的查询结果。

工作原理图

右击 root@localhost 创建 db1注:基字符集一定要 uft8,别问为什么,本人因为这被折磨了半小时)输入名称 user

 或者用 sql 语句创建

CREATE DATABASE db1;USE db1;CREATE TABLE `user`(`id` INT,`name` VARCHAR(30));INSERT INTO `user` VALUES (1,'张一'),(2,'张二'),(3,'张三'),(4,'张四'),(5,'张五');

1、连接 MySQL 

(1)、注册驱动

Class.forName("com.mysql.cj.jdbc.Driver");

(2)、获取连接

Connection com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");

(3)、获取执行者连接

Statement stat = com.createStatement();

(4)、执行 SQL 语句,并接受结果

String sql = "SELECT * FROM user";ResultSet rs = stat.executeQuery(sql);

(5)、处理结果

while (rs.next()){        System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));}

(6)、释放资源

com.close();stat.close();com.close();

代码连接起来

package com.text.jdbc;import java.sql.*;public class jbdc {    public static void main(String[] args) throws Exception {        Class.forName("com.mysql.cj.jdbc.Driver");        Connection com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");        // DriverManager 注册驱动        // Connection 数据库连接对象  url(指定连接的路径 语法:“jdbc:mysql://ip地址:端口号/数据库名称”)        Statement stat = com.createStatement();        //执行 sql 语句的对象        String sql = "SELECT * FROM user";        ResultSet rs = stat.executeQuery(sql);        // 执行 增删改查 (DML)语句用 int executeUpdate(Sting sql);        // 执行 DQL 语句 ResultSet executeQuery(String sql);        // 对象释放 void close();        while (rs.next()){            System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));        }        com.close();        stat.close();        com.close();    }}

这里有个小细节,在步骤一中,注册驱动那,如果忘了驱动名或者敲错了,可以在 lib -> mysql-connector-java.jar -> jdbc -> Driver 里面查看

点击运行,控制台读取数据库的数据,完成连接。 

1、准备工作

       首先我们创建好数据库(名为db1)数据表(名为student),并添加好数据 (这是我们的总表),如图:

       在前面我们用 jdbc 类 打印出所有的数据表信息,这里我们换一种方式,升级版

       这里我们创建 controller包(里面有 StudentController 类)、dao包(里面有 StudentDao 接口、StudentDaoImpl 类)、daomian 包(里面有 Student 类)、service 包(里面有 StudentService 接口、StudentServiceImpl 类),如图,并写入代码:

StudentController 类:

package com.inxzw.domain.controller;import com.inxzw.domain.domain.Student;import com.inxzw.domain.service.StudentService;import com.inxzw.domain.service.StudentServiceImpl;import org.testng.annotations.Test;import java.util.ArrayList;public class StudentController {    private StudentService service = new StudentServiceImpl();    @Test    public void findAll(){        ArrayList list = service.findAll();        for (Student stu : list){            System.out.println(stu);        }    }    public void findById(){    }}

 StudentDao 接口:

package com.inxzw.domain.dao;import com.inxzw.domain.domain.Student;import java.util.ArrayList;public interface StudentDao {    // 查询所有学生信息    public abstract ArrayList findAll();    //获取id    public abstract Student findById(Integer id);//    新增信息    public abstract int insert(Student stu);//    修改信息    public abstract int update(Student stu);//    删除信息    public abstract int delete(Integer id);}
StudentDaoImpl类:
package com.inxzw.domain.dao;import com.inxzw.domain.domain.Student;import java.sql.*;import java.util.ArrayList;import java.util.Date;public class StudentDaoImpl implements StudentDao{    @Override    public ArrayList findAll(){        Connection com = null;        Statement stat = null;        ResultSet rs = null;        ArrayList list = new ArrayList<>();        try {            Class.forName("com.mysql.cj.jdbc.Driver");            com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");            stat = com.createStatement();            String sql = "SELECT * FROM student";            rs = stat.executeQuery(sql);            while (rs.next()){//                System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));                Integer sid = rs.getInt("sid");                String name = rs.getString("name");                Integer age = rs.getInt("age");                Date birthday = rs.getDate("birthday");                Student stu = new Student(sid,name,age,birthday);                list.add(stu);            }        }catch (Exception e){            e.printStackTrace();        }finally {            if (com != null)            {                try {                    com.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }            if (stat != null)            {                try {                    stat.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }            if (rs != null)            {                try {                    rs.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }        }        return list;    }    @Override    public Student findById(Integer id) {        return null;    }    @Override    public int insert(Student stu) {        return 0;    }    @Override    public int update(Student stu) {        return 0;    }    @Override    public int delete(Integer id) {        return 0;    }}
Student 类:
package com.inxzw.domain.domain;import java.util.Date;public class Student {    private Integer sid;    private String name;    private  Integer age;    private Date birthday;    public Student(Integer sid, String name, Integer age, Date birthday) {        this.sid = sid;        this.name = name;        this.age = age;        this.birthday = birthday;    }    public Integer getSid() {        return sid;    }    public void setSid(Integer sid) {        this.sid = sid;    }    public String getName() {        return name;    }    public void setName(String name) {        this.name = name;    }    public Integer getAge() {        return age;    }    public void setAge(Integer age) {        this.age = age;    }    public Date getBirthday() {        return birthday;    }    public void setBirthday(Date birthday) {        this.birthday = birthday;    }    @Override    public String toString() {//打印        return "Student{" +                "sid=" + sid +                ", name='" + name + '\'' +                ", age=" + age +                ", birthday=" + birthday +                '}';    }}
StudentService 接口:
package com.inxzw.domain.service;import com.inxzw.domain.domain.Student;import java.util.ArrayList;public interface StudentService {    public abstract ArrayList findAll();    public abstract Student findById(Integer id);    public abstract int insert(String stu);    public abstract int update(Student stu);    public abstract int delete(Integer id);}
StudentServiceImpl 类:
package com.inxzw.domain.service;import com.inxzw.domain.dao.StudentDao;import com.inxzw.domain.dao.StudentDaoImpl;import com.inxzw.domain.domain.Student;import java.util.ArrayList;public class StudentServiceImpl implements StudentService{    private StudentDao dao = new StudentDaoImpl();    public ArrayList findAll(){        return dao.findAll();    }    public Student findById(Integer id){        return null;    }    @Override    public int insert(String stu) {        return 0;    }    @Override    public int update(Student stu) {        return 0;    }    @Override    public int delete(Integer id) {        return 0;    }}

       在 StudentController 类(控制类) ,运行 findAll() ,记得要加 @Text ,点击运行。完成查询所有信息。

1、根据 id 获取信息

我们可以通过 id 来获取属性,eg:通过 id 为 5 来查询元组。代码如下:

StudentDaoImpl 类:

public Student findById(Integer id) {        Student stu = new Student();        Connection com = null;        Statement stat = null;        ResultSet rs = null;        ArrayList list = new ArrayList<>();        try {            Class.forName("com.mysql.cj.jdbc.Driver");            com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");            stat = com.createStatement();            String sql = "SELECT * FROM student WHERE sid = '"+id+"' ";            rs = stat.executeQuery(sql);            while (rs.next()){//                System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));                Integer sid = rs.getInt("sid");                String name = rs.getString("name");                Integer age = rs.getInt("age");                Date birthday = rs.getDate("birthday");                stu.setSid(sid);                stu.setName(name);                stu.setAge(age);                stu.setBirthday(birthday);            }        }catch (Exception e){            e.printStackTrace();        }finally {            if (com != null)            {                try {                    com.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }            if (stat != null)            {                try {                    stat.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }            if (rs != null)            {                try {                    rs.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }        }        return stu;    }
StudentServiceImpl 类:
    public Student findById(Integer id){        return dao.findById(id);    }
StudentController 类:
    public void findById(){        Student stu = service.findById(4);//查询3号记录        System.out.println(stu);    }

        点击运行,完成查询。

2、添加信息

StudentDaoImpl 类:

    @Override    public int insert(Student stu) {        Connection com = null;        Statement stat = null;        int result = 0;        try {            Class.forName("com.mysql.cj.jdbc.Driver");            com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");            stat = com.createStatement();            Date d = stu.getBirthday();            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");            String birthday = sdf.format(d);            String sql = "INSERT INTO student VALUES ('"+stu.getSid()+"','"+stu.getName()+"','"+stu.getAge()+"','"+birthday+"')";            result = stat.executeUpdate(sql);        }catch (Exception e){            e.printStackTrace();        }finally {            if (com != null)            {                try {                    com.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }            if (stat != null)            {                try {                    stat.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }        }        return result;    }

StudentServiceImpl 类:

    public int insert(Student stu) {        return dao.insert(stu);    }
StudentController 类:
    public void insert(){        Student stu = new Student(9, "张九", 29, new Date());        int result = service.insert(stu);        if (result != 0){            System.out.println("添加成功");        }else {            System.out.println("添加失败");        }    }

         点击运行,显示出添加成功,我们用 findAll() 来查看表信息,完成添加。

3、修改信息

StudentDaoImpl 类:

    public int update(Student stu) {        Connection com = null;        Statement stat = null;        int result = 0;        try {            Class.forName("com.mysql.cj.jdbc.Driver");            com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");            stat = com.createStatement();            Date d = stu.getBirthday();            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");            String birthday = sdf.format(d);            String sql = "UPDATE student SET sid = '"+stu.getSid()+"', name = '"+stu.getName()+"', age = '"+stu.getAge()+"',birthday = '"+birthday+"' WHERE sid = '"+stu.getSid()+"'";            result = stat.executeUpdate(sql);        }catch (Exception e){            e.printStackTrace();        }finally {            if (com != null)            {                try {                    com.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }            if (stat != null)            {                try {                    stat.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }        }        return result;    }

StudentServiceImpl 类:

    public int update(Student stu) {        return dao.update(stu);    }

StudentController 类:

    @Test    public void update(){        Student stu = service.findById(5);        stu.setName("张五点五");        int result = service.update(stu);        if (result != 0){            System.out.println("修改成功");        }else {            System.out.println("修改失败");        }    }

        点击运行,显示出修改成功,我们用 findAll() 来查看表信息,完成修改。

4、删除信息

StudentDaoImpl 类:

public int delete(Integer id) {        Connection com = null;        Statement stat = null;        int result = 0;        try {            Class.forName("com.mysql.cj.jdbc.Driver");            com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");            stat = com.createStatement();            String sql = "DELETE FROM student WHERE sid = '"+id+"'";            result = stat.executeUpdate(sql);        }catch (Exception e){            e.printStackTrace();        }finally {            if (com != null)            {                try {                    com.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }            if (stat != null)            {                try {                    stat.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }        }        return result;    }

StudentServiceImpl 类:

    public int delete(Integer id) {        return dao.delete(id);    }

StudentController 类:

    @Test    public void delete(){        int result = service.delete(5);        if (result != 0){            System.out.println("删除成功");        }else {            System.out.println("删除失败");        }    }

       点击运行,显示出删除成功,我们用 findAll() 来查看表信息,完成删除(我们删除了张五点五那一行信息)。

       在这里我们完成了对数据表进行了增删改查操作,最后来看 StudentDaoImpl 类中发现我们已经写了 300 多行代码,而且我们还写了,非常多的重复代码,效率非常的底,所以为了减少代码量,这里我们需要优化。

       我们创建一个新的包名叫 utils ,新建类 JDBCutils,然后创建配置文件 config.properties

           在 JDBCutils 类里面:“构造私有方法、声明所需要的配置变量、注册驱动、获取数据库连接方法、释放资源方法” ,代码如下:

    private JDBCutils(){}    // 声明所需要的配置变量    private static String driverClass;    private static String url;    private static String username;    private static String password;    private static Connection con;    //提供静态代码块,读取配置文件信息为变量赋值,注册驱动    static {        try {            InputStream is = JDBCutils.class.getClassLoader().getResourceAsStream("config.properties");            Properties prop = new Properties();            prop.load(is);            driverClass = prop.getProperty("driverClass");            url = prop.getProperty("url");            username = prop.getProperty("username");            password = prop.getProperty("password");        } catch (IOException e) {            e.printStackTrace();        }    }    // 获取数据库连接方法    public static Connection getConecction(){        try {            con = DriverManager.getConnection(url,username,password);        } catch (SQLException e) {            e.printStackTrace();        }        return con;    }    //释放资源方法    public static void close(Connection con, Statement stat, ResultSet rs){        if (con != null){            try {                con.close();            } catch (SQLException e) {                e.printStackTrace();            }        }        if (stat != null){            try {                stat.close();            } catch (SQLException e) {                e.printStackTrace();            }        }    }    public static void close(Connection con, Statement stat){        if (con != null){            try {                con.close();            } catch (SQLException e) {                e.printStackTrace();            }        }    }

 config.properties :

driverClass = com.mysql.cj.jdbc.Driverurl = jdbc:mysql://10.16.158.90:3306/db1username = rootpassword = 123456

我们已经创建好了准备工作,下面来看看 findAll() 是如何优化的

首先,这两步是可以替换掉的

之前:

Class.forName("com.mysql.cj.jdbc.Driver");com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");

 之后:

com = JDBCutils.getConecction();

之前:

            if (com != null)            {                try {                    com.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }            if (stat != null)            {                try {                    stat.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }            if (rs != null)            {                try {                    rs.close();                } catch (SQLException e) {                    e.printStackTrace();                }            }

 之后:

JDBCutils.close(com, stat, rs);

 现在看是不是感觉很爽?是不是省去了很多代码?点击运行,看看是否能跑起来。

 ok,运行没问题,优化成功。

然后,findById()、insert()、update()、delete() 方法操作都一样,这里就不一一显示了。

首先,我们还是这张 student 这张表,对这张表进行增删改查操作。

1、查询操作

我们要查询所有信息,其实方法都差不多,和上面的 MYSQL 的那 5 步是一样的,所以这里就不一一再次讲解了,直接看代码。

<%@ page language="java" import="java.sql.Connection" contentType="text/html; charset=UTF-8"         pageEncoding="GB18030"%><%@ page import="java.sql.*" %><%@ page import="java.util.Date" %>  JSP 读取数据库  <%    String driverClass="com.mysql.jdbc.Driver";    String url="jdbc:mysql://localhost/db1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC";    String user="root";    String password="123456";    Connection conn;    try{      Class.forName(driverClass);      conn=DriverManager.getConnection(url, user, password);      Statement stmt = conn.createStatement();      // 查询所有信息      String sql = "select * from student";      ResultSet rs = stmt.executeQuery(sql);      while(rs.next()){        Integer id = rs.getInt("id");        String name = rs.getString("name");        Integer age = rs.getInt("age");        Date birthday = rs.getDate("birthday");        out.println(id + "  " + name + "  " + age + "  " + birthday + "
"); } }catch (Exception ex){ ex.printStackTrace(); } %>

 注意:这里有一个小细节,在mysql 6.0版本之上必须配置的操作!properties配置文件内,单独写上url的地址是不对的,需要在url文本末尾加上  ?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC  这句话。一定要加上,本人 Debug 了一个多小时,千万别被 java 语法迷惑了,一定要加上!!!

2、增加操作

我们先看代码

<%@ page language="java" import="java.sql.Connection" contentType="text/html; charset=UTF-8"         pageEncoding="GB18030"%><%@ page import="java.sql.*" %><%@ page import="java.util.Date" %>    JSP 读取数据库    <%        String driverClass="com.mysql.jdbc.Driver";        String url="jdbc:mysql://localhost/db1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC";        String user="root";        String password="123456";        Connection conn;        try{            Class.forName(driverClass);            conn=DriverManager.getConnection(url, user, password);            Statement stmt = conn.createStatement();           String sql = "insert into student(id,name,age,birthday) VALUES (10,'张十',23,'2000-12-23')";            int rs = stmt.executeUpdate(sql);            if(rs == 0 ){                out.print("增加失败");            }else {                out.print("增加成功");            }        }catch (Exception ex){            ex.printStackTrace();        }    %>

 注意这里还有个细节(细节都是头发换来的,呜呜呜),我们服务器启动完成之后,这里一定要在浏览器执行一下,否则的话,对数据库没有任何操作。一定要记住!!!

刷新数据库,查看效果

3、修改操作

这里我们要把  “张十” 的 id 改为 12,那么对应的语句是   UPDATE student SET id = 12 where name='张十',我们看下代码

<%@ page language="java" import="java.sql.Connection" contentType="text/html; charset=UTF-8"         pageEncoding="GB18030"%><%@ page import="java.sql.*" %><%@ page import="java.util.Date" %>    JSP 读取数据库    <%        String driverClass="com.mysql.jdbc.Driver";        String url="jdbc:mysql://localhost/db1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC";        String user="root";        String password="123456";        Connection conn;        try{            Class.forName(driverClass);            conn=DriverManager.getConnection(url, user, password);            Statement stmt = conn.createStatement();            String sql="UPDATE student SET id = 12 where name='张十'";            int rs = stmt.executeUpdate(sql);            if(rs == 0 ){                out.print("修改失败");            }else {                out.print("修改成功");            }        }catch (Exception ex){            ex.printStackTrace();        }    %>

点击运行,记得在浏览器运行一次,ok,完成修改

效果如下

 4、删除操作

我们将 id 为 12的条件删除掉,这里同样先给出语句   "DELETE FROM student WHERE id=12"

先来看代码

<%@ page language="java" import="java.sql.Connection" contentType="text/html; charset=UTF-8"         pageEncoding="GB18030"%><%@ page import="java.sql.*" %><%@ page import="java.util.Date" %>    JSP 读取数据库    <%        String driverClass="com.mysql.jdbc.Driver";        String url="jdbc:mysql://localhost/db1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC";        String user="root";        String password="123456";        Connection conn;        try{            Class.forName(driverClass);            conn=DriverManager.getConnection(url, user, password);            Statement stmt = conn.createStatement();            String sql="DELETE FROM student WHERE id=12";            int rs = stmt.executeUpdate(sql);            if(rs == 0 ){                out.print("删除失败");            }else {                out.print("删除成功");            }        }catch (Exception ex){            ex.printStackTrace();        }    %>

这里浏览器显示删除成功 

刷新来看下效果

小结:大家在 StudentDaoImpl 类中有一个小细节,在 DriverManager.getConnection 中设置(“jdbc:mysql://ip地址:端口号/数据库名称”)ip 地址这里,在换地方写代码时,一定要记得改,我debug 了一小时才发现,我一直在想为什么上午下午在图书馆里面有用,晚上在寝室就没用了?血淋淋的痛啊~ 亲们,一定要记得改!

(求关注)持续更新中……

来源地址:https://blog.csdn.net/aasd23/article/details/124218870

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

JDBC 连接 MySQL

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

JDBC连接MySQL

依赖 mysql mysql-connector-java 5.1.27 代码实现import java.sql.Connection;import

	JDBC连接MySQL
2016-03-07

JDBC连接MySQL详解

JDBC(Java Database Connectivity)是Java语言访问数据库的标准方法,通过JDBC可以连接各种类型的数据库,包括MySQL。连接MySQL数据库需要以下步骤:加载数据库驱动:使用Class.forName(“
JDBC连接MySQL详解
2024-04-09

jdbc怎么连接MySQL

要连接MySQL数据库,可以使用JDBC(Java Database Connectivity)库。以下是连接MySQL数据库的步骤:1. 下载并安装MySQL Connector/J驱动程序。可以在MySQL官方网站上找到最新的驱动程序。
2023-09-16

jdbc-使用java连接mysql

package com.cqust;import com.mysql.jdbc.Driver;import java.sql.Connection;import java.sql.DriverManager;import java.sql.Statement;
jdbc-使用java连接mysql
2019-12-08

jdbc连接MySql数据库

jdbc连接MySql数据库package com.zhy;import com.mysql.jdbc.Driver;import java.sql.*;public class Te

	jdbc连接MySql数据库
2020-09-18

hbuilder怎么配置jdbc连接MySQL

要配置jdbc连接MySQL,可以按照以下步骤进行操作:1、在项目中添加MySQL的驱动包(JDBC驱动),通常是mysql-connector-java.jar。将该驱动包添加到项目的classpath中。2、在项目中创建一个prop
hbuilder怎么配置jdbc连接MySQL
2024-04-08

eclipse怎么配置jdbc连接MySQL

要配置Eclipse连接MySQL需要以下几个步骤:1. 下载并安装MySQL JDBC驱动:访问MySQL官方网站或者搜索引擎查询MySQL JDBC驱动下载链接。下载适合您MySQL版本的驱动程序并解压。2. 打开Eclipse,并进入
2023-09-15

jdbc连接mysql的五种方式

public void testConnection1() throws SQLException {// 获取Driver的实现类对象Driver driver = new com.mysql.jdbc.Driver();// 第三方的api;String
jdbc连接mysql的五种方式
2021-03-31

jdbc怎么连接mysql数据库

要连接MySQL数据库,需要以下步骤:1. 加载MySQL的JDBC驱动程序。可以从MySQL官方网站下载并安装MySQL Connector/J驱动程序,然后将驱动程序的JAR文件添加到项目的类路径下。2. 使用JDBC的`DriverM
2023-08-19

jdbc 连接 mysql 时需要留意哪些要点?(jdbc连接mysql要注意哪些事项)

在使用 jdbc 连接 mysql 数据库时,有许多需要注意的事项,以下是详细的介绍:

一、驱动程序的选择与配置

  1. 选择合适的驱动程序
    • MySQL 提供了多种 jdbc 驱动程序,常见的有 com.mysql.jdbc.Driver 和 com.mysql.cj.jdbc.Driver。在较新的 MySQL 版本中,推荐使用 com.mysql.cj.jdbc.Driver,它提供了更好的兼容性和性能。
    • 在项目的构建文件(如 Maven 的 pom.xml 或 Gradle 的 build.gradle)中添加相应的驱动依赖。例如,在 Maven 中:
      <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>8.0.26</version>
      </dependency>
  2. 配置驱动类路径
    • 将驱动 jar 包添加到项目的类路径中。可以通过将 jar 包复制到项目的 lib 目录下,并在项目的构建路径中包含该目录来实现。
    • 或者,在一些集成开发环境(IDE)中,可以直接将驱动 jar 包添加到项目的依赖库中,IDE 会自动处理类路径的配置。

二、数据库连接参数的设置

  1. 主机名、端口号、数据库名
    • 指定要连接的 MySQL 数据库的主机名和端口号。默认情况下,MySQL 监听本地主机的 3306 端口。如果数据库在远程服务器上,需要指定远程服务器的主机名和端口号。
    • 指定要连接的数据库名称。
  2. 用户名和密码
    • 使用具有足够权限的用户名和密码来连接数据库。确保用户名和密码的安全性,避免将它们硬编码在代码中,可以使用配置文件或环境变量来存储敏感信息。
  3. 连接超时和重试机制
    • 设置连接超时时间,以避免长时间等待连接建立。可以在连接 URL 中指定连接超时时间,例如:jdbc:mysql://localhost:3306/mydb?connectTimeout=5000&autoReconnect=true
    • 启用自动重连机制,以在连接断开时自动尝试重新连接。autoReconnect=true 参数可以实现自动重连。

三、SQL 语句的编写与执行

  1. 防止 SQL 注入
    • 避免直接将用户输入拼接在 SQL 语句中,这可能导致 SQL 注入攻击。使用参数化查询或预处理语句来代替字符串拼接。
    • 在 Java 中,可以使用 PreparedStatement 来执行参数化查询。例如:
      String sql = \"SELECT * FROM users WHERE username =? AND password =?\";
      PreparedStatement statement = connection.prepareStatement(sql);
      statement.setString(1, username);
      statement.setString(2, password);
      ResultSet resultSet = statement.executeQuery();
  2. 处理结果集
    • 在执行查询语句后,需要处理结果集。确保正确地获取和处理查询结果,避免内存泄漏和资源浪费。
    • 使用 ResultSet 对象来遍历结果集,并获取所需的数据。在处理完结果集后,记得关闭 ResultSet、Statement 和 Connection 对象。
      while (resultSet.next()) {
      // 获取数据
      String username = resultSet.getString(\"username\");
      String password = resultSet.getString(\"password\");
      // 处理数据
      }
      resultSet.close();
      statement.close();
      connection.close();

四、连接池的使用

  1. 避免频繁创建和销毁连接
    • 频繁创建和销毁数据库连接会消耗系统资源并降低性能。使用连接池来管理数据库连接,可以提高性能和效率。
    • 连接池维护一组数据库连接,应用程序从连接池中获取连接,使用完毕后将连接归还给连接池,而不是直接关闭连接。
  2. 选择合适的连接池实现
    • 有许多开源的连接池实现可供选择,如 Apache Commons DBCP、C3P0、BoneCP 等。这些连接池实现提供了连接池管理、连接复用、连接监控等功能。
    • 在选择连接池实现时,需要考虑性能、功能、稳定性等因素,并根据项目的需求进行选择。

五、错误处理与日志记录

  1. 捕获和处理数据库连接异常
    • 在连接数据库和执行 SQL 语句时,可能会遇到各种异常,如连接超时、数据库不可用、SQL 语法错误等。需要捕获这些异常,并进行适当的处理。
    • 使用 try-catch 块来捕获异常,并在 catch 块中处理异常情况。可以记录异常信息、回滚事务(如果有)或向用户显示友好的错误消息。
      try {
      // 连接数据库和执行 SQL 语句
      } catch (SQLException e) {
      e.printStackTrace();
      // 处理异常
      }
  2. 记录数据库操作日志
    • 为了便于调试和监控数据库操作,建议记录数据库操作的日志。可以使用日志框架(如 Log4j、Logback 等)来记录数据库操作的日志。
    • 在代码中添加日志记录语句,记录重要的数据库操作和异常信息。这样可以帮助开发人员快速定位问题和进行故障排查。

总之,在使用 jdbc 连接 mysql 数据库时,需要注意驱动程序的选择与配置、数据库连接参数的设置、SQL 语句的编写与执行、连接池的使用以及错误处理与日志记录等方面。遵循这些注意事项,可以提高数据库连接的稳定性和性能,确保应用程序的正常运行。

jdbc 连接 mysql 时需要留意哪些要点?(jdbc连接mysql要注意哪些事项)
2024-12-13

JDBC连接Mysql的方式有哪些

本篇内容主要讲解“JDBC连接Mysql的方式有哪些”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“JDBC连接Mysql的方式有哪些”吧!测试环境说明mysql数据库:jdbc:mysql://
2023-07-05

编程热搜

目录