欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

JDBC数据库的使用操作总结

程序员文章站 2024-02-18 14:32:58
jdbc是一组能够执行sql语句的api 由于传统的数据库操作方式需要程序员掌握各个不同的数据库的api,极其不便 因此java定义了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数据库的使用操作总结