JDBC 连接 MySQL(jdbc连接mysql数据库不成功)

JDBC 连接 MySQL

推荐整理分享JDBC 连接 MySQL(jdbc连接mysql数据库不成功)，希望有所帮助，仅作参考，欢迎阅读内容。

文章相关热门搜索词:jdbc连接mysql数据库不成功,jdbc连接mysql实现增删改查,jdbc连接mysql数据库不成功,jdbc连接mysql配置文件,jdbc连接mysql配置文件,jdbc连接mysql配置文件,jdbc连接MySQL步骤,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 执行后所产生的查询结果。

工作原理图

三、数据库的创建（MySQL）

右击 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 里面查看

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

四、对 MySQL 进行增删改查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<Student> 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<Student> 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<Student> findAll(){ Connection com = null; Statement stat = null; ResultSet rs = null; ArrayList<Student> 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<Student> 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<Student> 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 ，点击运行。完成查询所有信息。

五、JDBC 实践操作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<Student> 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 类里面：“构造私有方法、