MySQL五步走JDBC编程全解读

目录

• 一、数据库编程的必备条件
• 二、java的数据库编程：jdbc
• 三、jdbc工作原理
• 四、开发环境搭建
• 五、mysql中的jdbc编程
• 1、五步流程
• 2、添加信息
• 3、查询信息
• 4、删除信息
• 5、修改信息

一、数据库编程的必备条件

编程语言，如java，c、c++、python等 数据库，如oracle，mysql，sql server等 数据库驱动包：不同的数据库，对应不同的编程语言提供了不同的数据库驱动包，如：mysql提 供了java的驱动包mysql-connector-java，需要基于java操作mysql即需要该驱动包。同样的， 要基于java操作oracle数据库则需要oracle的数据库驱动包ojdbc。

二、java的数据库编程：jdbc

jdbc，即java database connectivity，java数据库连接。是一种用于执行sql语句的java api，它是 java中的数据库连接规范。这个api由 java.sql.*,javax.sql.* 包中的一些类和接口组成，它为java 开发人员操作数据库提供了一个标准的api，可以为多种关系数据库提供统一访问。

三、jdbc工作原理

dbc 为多种关系数据库提供了统一访问方式，作为特定厂商数据库访问api的一种高级抽象，它主要包 含一些通用的接口类。

jdbc访问数据库层次结构:

四、开发环境搭建

首先在电脑服务当中查看自己mysql的版本，然后进入maven仓库

因为我自己的版本是5.0之后的，所以我选择5.1.47，大版本要一致

 下载jar即可，记住，jar包不能解压缩

接下来就在idea自己在根目录下创建文件夹，然后导入jar包

 没有报错一直ok下去就没有啥问题，说明导入成功

五、mysql中的jdbc编程

1、五步流程

建立数据库连接

// 加载jdbc驱动程序：反射，这样调用初始化com.mysql.jdbc.driver类，即将该类加载到jvm方法
区，并执行该类的静态方法块、静态属性。
class.forname("com.mysql.jdbc.driver");
// 创建数据库连接
connection connection =
drivermanager.getconnection("jdbc:mysql://localhost:3306/test?
user=root&password=root&useunicode=true&characterencoding=utf-8");

//mysql数据连接的url参数格式如下：
jdbc:mysql://服务器地址:端口/数据库名?参数名=参数值

创建操作命令（statement）

statement statement = connection.createstatement();

执行sql语句

resultset resultset= statement.executequery(
                "select id, sn, name, qq_mail, classes_id from student");

处理结果集

while (resultset.next()) {
            int id = resultset.getint("id");
            string sn = resultset.getstring("sn");
            string name = resultset.getstring("name");
            int classesid = resultset.getint("classes_id");
            system.out.println(string.format("student: id=%d, sn=%s, name=%s, 
classesid=%s", id, sn, name, classesid));
       }

释放资源（关闭结果集，命令，连接）

//关闭结果集
if (resultset != null) {
    try {
        resultset.close();
   } catch (sqlexception e) {
        e.printstacktrace();
   }
}
//关闭命令
if (statement != null) {
    try {
        statement.close();
   } catch (sqlexception e) {
        e.printstacktrace();
   }
}
//关闭连接命令
if (connection != null) {
    try {
        connection.close();
   } catch (sqlexception e) {
        e.printstacktrace();
   }
}

2、添加信息

首先创建一个数据库并且创建一个表

 create database java122;

 create table text(id int,name varchar(5),class_id int);

import com.mysql.jdbc.jdbc2.optional.mysqldatasource;
import javax.sql.datasource;
import java.sql.connection;
import java.sql.preparedstatement;
import java.sql.sqlexception;
 
 
public class textjdbc {
    //datasource
    //connection
    //preparestatement
 
 
    public static void main(string[] args) throws sqlexception{
        //1、创建datasource对象
         datasource datasource = new mysqldatasource();
        //设置相关内容
        //url user password
        //向下转型                     访问数据库   协议名        ip地址 要访问那个地址
        ((mysqldatasource) datasource).seturl("jdbc:mysql://127.0.0.1:3306/java122?characterencoding=utf-8&usessl=false");
        ((mysqldatasource) datasource).setuser("root");
        ((mysqldatasource) datasource).setpassword("180210");
        
        //2、和数据库连接.进行后续连接
        //connect生命周期较短
        connection connection = datasource.getconnection();
        
        //3、拼装sql语句
        int id = 1;
        string name = "曹操";
        int class_id = 10;
        //?是一个占位符，可以把一个具体的变量的值替换到？
        string sql = "insert into text values(?,?,?)";
        preparedstatement statement = connection.preparestatement(sql);
        //1 2 3相当与？的下标
        statement.setint(1,id);
        statement.setstring(2,name);
        statement.setint(3,class_id);
        system.out.println("statement:" + statement);
 
        //4、执行sql语句
        int ret = statement.executeupdate();
        system.out.println("ret:" + ret);
 
        //5、关闭相关资源
        //后创建的先释放，顺序不能错
        statement.close();
        connection.close();
 
    }
}

3、查询信息

import com.mysql.jdbc.jdbc2.optional.mysqldatasource;
 
import javax.sql.datasource;
import javax.xml.transform.source;
import java.sql.connection;
import java.sql.preparedstatement;
import java.sql.resultset;
import java.sql.sqlexception;
import java.util.scanner;
 
public class text1 {
 
 
    public static void main(string[] args) throws sqlexception {
 
        //1，创建实列
        datasource datasource = new mysqldatasource();
        ((mysqldatasource)datasource).seturl("jdbc:mysql://127.0.0.1:3306/java122?characterencoding=utf-8&usessl=false");
        ((mysqldatasource)datasource).setuser("root");
        ((mysqldatasource)datasource).setpassword("180210");
 
        //2，数据库连接
        connection connection = datasource.getconnection();
 
        //3,构造sql语句
 
        string sql ="select * from text";
        preparedstatement statement = connection.preparestatement(sql);
 
        //4,执行sql语句
        resultset resultset = statement.executequery();
        while (resultset.next()){
            int id = resultset.getint("id");
            string name = resultset.getstring("name");
            int class_id = resultset.getint("class_id");
            system.out.println("id: " + id  + "name: " + name  + "class_id: " + class_id);
        }
 
        //5,关闭相关资源
        resultset.close();
        statement.close();
        connection.close();
    }
}

4、删除信息

import com.mysql.jdbc.jdbc2.optional.mysqldatasource;
 
import javax.sql.datasource;
import java.sql.connection;
import java.sql.preparedstatement;
import java.sql.sqlexception;
import java.util.scanner;
 
public class textur2 {
 
 
    public static void main(string[] args) throws sqlexception {
 
 
        scanner scanner = new scanner(system.in);
        system.out.println("请输入要删除学生的姓名：");
        string name = scanner.next();
        //1，创建实列
        datasource datasource = new mysqldatasource();
        ((mysqldatasource) datasource).seturl("jdbc:mysql://127.0.0.1:3306/java122?characterencoding=utf-8&usessl=false");
        ((mysqldatasource) datasource).setuser("root");
        ((mysqldatasource) datasource).setpassword("180210");
 
        //2，数据库连接
        connection connection = datasource.getconnection();
 
        //3,构造sql语句
        string sql = "delete from text where name = ?";
        preparedstatement statement = connection.preparestatement(sql);
        statement.setstring(1,name);
 
        //4,执行sql
        int ret = statement.executeupdate();
        if (ret == 1){
            system.out.println("删除成功");
        }else {
            system.out.println("删除失败");
        }
 
        //5，关闭资源
        statement.close();
        connection.close();
 
 
    }
}

5、修改信息

import com.mysql.jdbc.jdbc2.optional.mysqldatasource;
 
import javax.sql.datasource;
import java.sql.connection;
import java.sql.preparedstatement;
import java.sql.sqlexception;
import java.util.scanner;
 
public class text4 {
 
 
    public static void main(string[] args) throws sqlexception {
 
 
        //修改信息
        scanner scanner = new scanner(system.in);
        system.out.println("请输入学生的id：");
        int id = scanner.nextint();
        system.out.println("请输入修改学生姓名：");
        string name = scanner.next();
 
        //1，创建实列
        datasource datasource = new mysqldatasource();
        ((mysqldatasource) datasource).seturl("jdbc:mysql://127.0.0.1:3306/java122?characterencoding=utf-8&usessl=false");
        ((mysqldatasource) datasource).setuser("root");
        ((mysqldatasource) datasource).setpassword("180210");
 
        //2，数据库连接
        connection connection = datasource.getconnection();
 
        //3,拼装sql
        string sql = "update text set name = ? where id = ?";
        preparedstatement statement = connection.preparestatement(sql);
        statement.setstring(1,name);
        statement.setint(2,id);
        //4,执行sql
        int set = statement.executeupdate();
        if (set == 1){
            system.out.println("修改成功");
        }else {
            system.out.println("修改失败");
        }
 
        //5，关闭资源
        statement.close();
        connection.close();
    }
}

到此这篇关于mysql五步走jdbc编程全解读的文章就介绍到这了,更多相关mysql jdbc编程内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com！