服务器之家：专注于服务器技术及软件下载分享
分类导航

Mysql|Sql Server|Oracle|Redis|

服务器之家 - 数据库 - Mysql - JDBC数据库的使用操作总结

JDBC数据库的使用操作总结

2019-12-24 14:35MYSQL教程网 Mysql

本篇文章介绍了，JDBC数据库的使用操作方法的一些总结。需要的朋友可以参考一下

JDBC是一组能够执行SQL语句的API

由于传统的数据库操作方式需要程序员掌握各个不同的数据库的API，极其不便

因此java定义了JDBC这一标准的接口和类，为程序员操作数据库提供了统一的方式

JDBC的操作方式比较单一，由五个流程组成：

1.通过数据库厂商提供的JDBC类库向DriverManager注册数据库驱动

2.使用DriverManager提供的getConnection()方法连接到数据库

3.通过数据库的连接对象的createStatement方法建立SQL语句对象

4.执行SQL语句，并将结果集合返回到ResultSet中

5.使用while循环读取结果

6.关闭数据库资源

下面来看看具体操作Mysql数据库的方法


准备工作

首先我们需要建立一个数据库和一张简单的表

复制代码代码如下:


mysql> create database person;
Query OK, 1 row affected (0.00 sec)

 

mysql> use person;
Database changed
mysql> create table student(
    -> id int,
    -> name varchar(20),
    -> birth year
    -> ) default charset=utf8;
Query OK, 0 rows affected (0.10 sec)


然后往里面插入几条数据

复制代码代码如下:

mysql> insert into student values
    -> (1,'张三',1990),
    -> (2,'李四',1991),
    -> (3,'王五',1992);
Query OK, 3 rows affected (0.02 sec)
Records: 3  Duplicates: 0  Warnings: 0


这样一张简单的表就建好了

复制代码代码如下:

mysql> select * from student;
+------+--------+-------+
| id   | name   | birth |
+------+--------+-------+
|    1 | 张三   |  1990 |
|    2 | 李四   |  1991 |
|    3 | 王五   |  1992 |
+------+--------+-------+
 rows in set (0.00 sec)


接下来，去mysql官网下载数据库连接器这个包

 

其中这个包里面含有一份文档，里面列举了基本的使用方法，可以参考

我们的操作也是按照这份文档中的内容进行，然后最主要的地方就是导入这个jar包

JDBC,数据库

为了操作方便，这里使用eclipse来导入

右键项目-->构件路径-->添加外部归档，添加好了之后如下所示

JDBC,数据库

现在我们正式开始使用java来操作mysql数据库

JDBC操作实例1：最简单的查询操作

复制代码代码如下:


import java.sql.*;

 

public class Demo {
    //为了代码紧凑性，暂时抛出所有异常
    public static void main(String[] args) throws Exception {
        //注册数据库驱动
        Class.forName("com.mysql.jdbc.Driver");
        //建立数据库连接
        //参数一：jdbc：mysql//地址：端口/数据库,参数二：用户名，参数三：密码
        Connection conn = DriverManager.getConnection
                ("jdbc:mysql://localhost:3306/person","root","admin");
        //创建SQL语句
        Statement st = conn.createStatement();
        //执行语句，返回结果
        ResultSet rt = st.executeQuery("show tables");
        //循环取出结果
        while(rt.next()) {
            //获取字段
            System.out.println(rt.getString("Tables_in_person"));
        }
        //关闭资源，最先打开的最后关
        rt.close();
        st.close();
        conn.close();
    }
}


运行结果：student

 

如此便可执行show tables语句查询出当前数据库含有多少张表

其中rt.getString()方法是获取字段，这点需要注意

关闭资源的方式也与以往相反

不过，上面的操作方式灵活性不大，并且不严谨


实例2：优化的查询操作

复制代码代码如下:


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

 

public class Demo {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/person";
        String user = "root";
        String pwd = "admin";
        String sql = "select * from student";

        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection(url,user,pwd);
            st = conn.createStatement();
            //执行查询语句，另外也可以用execute()，代表执行任何SQL语句
            rs = st.executeQuery(sql);
            while(rs.next()) {
                System.out.println(rs.getObject(1) + "  " + 
                        rs.getObject(2) + "  " + rs.getInt("birth"));
            }
        //分别捕获异常
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                //判断资源是否存在
                if(rs != null) {
                    rs.close();
                    //显示的设置为空，提示gc回收
                    rs = null;
                }
                if(st != null) {
                    st.close();
                    st = null;
                }
                if(conn != null) {
                    conn.close();
                    conn = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }    
        }
    }
}


运行结果：

 

JDBC,数据库

这里把异常给分别捕获了，并且相关的字符串全部用变量定义

需要注意下循环取出数据里面的getInt()方法，此处必须知道类型和字段才能取出

如果不知道可以使用getObject(1)取出第一列，getObject(2)取出第二列，以此类推

实例3：自定义变量插入到数据库

复制代码代码如下:


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

 

public class Demo {
    public static void main(String[] args) {
        //参数检查
        if (args.length != 3) {
            System.out.println("参数形式不对");
            System.exit(0);
        }
        String id = args[0];
        String name = args[1];
        String birth = args[2];
        String sql = "insert into student values(" + id + ",'" + name + 
                "'," + "'" + birth + "')";
        System.out.println(sql);

        String url = "jdbc:mysql://localhost:3306/person";
        String user = "root";
        String pwd = "admin";

        Connection conn = null;
        Statement st = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection(url,user,pwd);
            st = conn.createStatement();
            //注意，此处是excuteUpdate()方法执行
            st.executeUpdate(sql);        
        //分别捕获异常
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if(st != null) {
                    st.close();
                    st = null;
                }
                if(conn != null) {
                    conn.close();
                    conn = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }    
        }
    }
}


运行结果：

 

JDBC,数据库

这里运行需要设置自变量，窗口中右键-->运行方式-->运行配置

然后在自变量里面写4 susan 1993，我没有写中文，因为产生乱码，目前还不清楚原因

需要注意的是，执行插入的SQL语句比较难写，最好是打印出SQL语句用以检查

实例4：PreparedStatement应用

从上面的Demo可以看到，插入数据的时候，SQL操作相当不便

这里可以使用PreparedStatement对象来简化SQL语句的建立

复制代码代码如下:


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

 

public class Demo {

    public static void main(String[] args) {
        if (args.length != 3) {
            System.out.println("参数形式不对");
            System.exit(0);
        }
        String id = args[0];
        String name = args[1];
        String birth = args[2];

        String url = "jdbc:mysql://localhost:3306/person";
        String user = "root";
        String pwd = "admin";

        Connection conn = null;
        //声明PreparedStatement对象的引用
        PreparedStatement pst = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection(url,user,pwd);
            //使用？代替变量
            pst = conn.prepareStatement("insert into student values (?,?,?)");
            //给指定参数的位置设定变量
            pst.setString(1, id);
            pst.setString(2, name);
            pst.setString(3, birth);
            pst.executeUpdate();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if(pst != null) {
                    pst.close();
                    pst = null;
                }
                if(conn != null) {
                    conn.close();
                    conn = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }    
        }
    }
}


运行结果：

 

JDBC,数据库

实例5：Batch批处理

复制代码代码如下:


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

 

public class Demo {

    public static void main(String[] args) {

        String url = "jdbc:mysql://localhost:3306/person";
        String user = "root";
        String pwd = "admin";

        Connection conn = null;
        Statement st = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection(url,user,pwd);
            st = conn.createStatement();
            //添加批处理
            st.addBatch("insert into student values(6,'Jerry','1995')");
            st.addBatch("insert into student values(7,'Greg','1996')");
            st.addBatch("insert into student values(8,'Ryan','1997')");
            //执行批处理
            st.executeBatch();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if(st != null) {
                    st.close();
                    st = null;
                }
                if(conn != null) {
                    conn.close();
                    conn = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }    
        }
    }
}


运行结果：

 

JDBC,数据库

批处理比较简单，只需先建立Statement对象，然后逐个添加批处理即可

最后使用executeBatch()方法执行批处理

此外，PreparedStatement对象也可以使用批处理

复制代码代码如下:

PreparedStatement ps = conn.prepareStatement("insert into student values(?,?,?)");
ps.setInt(1,8);
ps.setString(2,"GG");
ps.setString(3,"1996");
ps.addBatch();
ps.executeBatch();


实例6：Transaction事务处理

 

事务处理是要求sql以单元的形式更新数据库，要求其确保一致性

如银行的转账业务，一方转出后，另一方则增加

如果出现异常，那么所有的操作则会回滚

复制代码代码如下:


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

 

public class Demo {

    public static void main(String[] args) {

        String url = "jdbc:mysql://localhost:3306/person";
        String user = "root";
        String pwd = "admin";

        Connection conn = null;
        Statement st = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection(url,user,pwd);
            //取消自动提交
            conn.setAutoCommit(false);
            st = conn.createStatement();
            st.addBatch("insert into student values(6,'Jerry','1995')");
            st.addBatch("insert into student values(7,'Greg','1996')");
            st.addBatch("insert into student values(8,'Ryan','1997')");
            st.executeBatch();
            //提交后设置自动提交
            conn.commit();
            conn.setAutoCommit(true);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();

        } catch (SQLException e) {
            e.printStackTrace();

            if(conn != null) {
                try {
                    //出现异常则回滚操作，然后设置自动提交
                    conn.rollback();
                    conn.setAutoCommit(true);
                } catch (SQLException e1) {
                    e1.printStackTrace();
                }
            }
        } finally {
            try {
                if(st != null) {
                    st.close();
                    st = null;
                }
                if(conn != null) {
                    conn.close();
                    conn = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }    
        }
    }
}


运行结果：

 

JDBC,数据库

  • 数据库
  • JDBC

    • 延伸 · 阅读

    精彩推荐
    • Mysql配置MySQL与卸载MySQL实例操作

      配置MySQL与卸载MySQL实例操作

      我们主要介绍的是正确通过rpm包安装、对MySQL进行配置与卸载的实际操作步骤，以下就是文章的具体内容描述，望你会有所收获。 ...

      MySQL教程网2962019-11-11
    • Mysql关于MYSQL 远程登录的授权方法 命令

      关于MYSQL 远程登录的授权方法 命令

      默认是不允许远程连接的，因为有很大的安全隐患。需要手动增加可以远程访问数据库的用户 ...

      MYSQL教程网1772019-11-26
    • Mysqlmysql查询字符串替换语句小结(数据库字符串替换)

      mysql查询字符串替换语句小结(数据库字符串替换)

      有时候我们需要对mysql的字符串进行替换，我们就可以通过sql语句直接实现了，不过对于大数据量的字段不建议使用此方法 ...

      MYSQL教程网4452019-12-03
    • MysqlMysql全文搜索match against的用法

      Mysql全文搜索match against的用法

      全文检索在 MySQL 中就是一个 FULLTEXT 类型索引。FULLTEXT 索引用于 MyISAM 表，可以在 CREATE TABLE 时或之后使用 ALTER TABLE 或 CREATE INDEX 在 CHAR、 VARCHAR 或 TEXT 列上...

      MYSQL教程网2642019-11-26
    • Mysql使用MySQL Slow Log来解决MySQL CPU占用高的问题

      使用MySQL Slow Log来解决MySQL CPU占用高的问题

      在Linux VPS系统上有时候会发现MySQL占用CPU高，导致系统的负载比较高。这种情况很可能是某个SQL语句执行的时间太长导致的。优化一下这个SQL语句或者优化...

      MYSQL教程网4102019-12-21
    • Mysqlmysql limit分页优化方法分享

      mysql limit分页优化方法分享

      MySQL的优化是非常重要的。其他最常用也最需要优化的就是limit。MySQL的limit给分页带来了极大的方便，但数据量一大的时候，limit的性能就急剧下降。 ...

      MYSQL教程网4482019-11-16
    • Mysql在MySQL字段中使用逗号分隔符的方法分享

      在MySQL字段中使用逗号分隔符的方法分享

      大多数开发者应该都遇到过在mysql字段中存储逗号分割字符串的经历，无论这些被分割的字段代表的是id还是tag，这个字段都应该具有如下几个共性 ...

      MYSQL教程网1152019-12-03
    • MysqlMSSQL output使用

      MSSQL output使用

      存储过程 output 输出参数 可以是一个字符串 ...

      mssql教程网4692019-10-27
    最近更新
    编辑推荐
    阅读排行
    热门标签
    150 　 1862 　 1062 　 1044 　 1045 　 1053 　 1067 　 10061 　 1130 　 1406 　 #2003 　 mysql实时监控工具 　 mysql语句 　 Rotate 　 多主复制 　 DBI 　 utf8_unicode_ci 　 互为主从 　 主从备份 　 mytop 　 服务器无响应 　 Server2016 　 并发读 　 unsigned 　 NAMES 　 补数 　 查询记录效率 　 query_cache 　 utf8_general_ci 　 字符替换函数 　
    © 2019-2025 服务器之家 版权所有 www.zzvips.com 关于我们联系我们版权申明网站地图