当前位置:  数据库>mysql

JDBC数据库的使用操作总结

    来源: 互联网  发布时间：2014-10-09

    本文导语:  JDBC是一组能够执行SQL语句的API 由于传统的数据库操作方式需要程序员掌握各个不同的数据库的API，极其不便 因此java定义了JDBC这一标准的接口和类，为程序员操作数据库提供了统一的方式 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包

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

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

现在我们正式开始使用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();
            }   
        }
    }
}


运行结果：

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

需要注意下循环取出数据里面的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();
            }   
        }
    }
}


运行结果：

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

然后在自变量里面写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();
            }   
        }
    }
}


运行结果：

实例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();
            }   
        }
    }
}


运行结果：

批处理比较简单，只需先建立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();
            }   
        }
    }
}


运行结果：


    
 
 

您可能感兴趣的文章:

  • 谁知道mysql的哪个版本的jdbc驱动支持批操作，在哪儿下载？
  • 使用jdbc操作odbc数据源的问题！
  • 用Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");的情况下，可不可以用dbo的用户名和密码来操作自定义的数据库，要怎
  • 用jdbc对access数据库进行操作时出现异常：java.sql.SQLException: [Microsoft][ODBC 驱动程序 管理器] 非法的游标状态
  • java使用jdbc操作数据库示例分享
  • jboss高手请进，有关jdbc的问题！报错："对只转发结果集的无效操作"（急死我了！！！愿以200分送上！）
  • java.sql.Blob为什么不可以setBinaryStream的，只可以get，如果这样的话，在以前的jdbc版本中是怎样用BLOB数据类型来对表进行操作的，怎
  • jdbc操作数据库的基本流程详解
  • 浅析JAVA常用JDBC连接数据库的方法总结
    •  
    本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术，将尽最大努力为读者提供更好的信息聚合和浏览方式。
    本站(WWW.)站内文章除注明原创外，均为转载、整理或搜集自网络。欢迎任何形式的转载，转载请注明出处。












  • 相关文章推荐
  • mysql jdbc连接mysql数据库步骤及常见参数详解
  • java开发数据库，一般是用JDBC-ODBC桥，还是JDBC驱动程序连接数据库呢？
  • 请问连接本机数据库的JDBC，和连接远程的JDBC有没有区别？
  • jdbc连接数据库，能否有jdbc中的方法进行安全设置：
  • java通过jdbc访问数据库流行采用何种数据库驱动程序？jdbc-odbc , InterClient , 还是“网络协议/全java驱动程序”？如有可能，请给简明
  • Java数据库集群方案 C-JDBC
  • 请问哪里有JDBC数据库下载？
  • 关于数据库JDBC驱动程序
  • 用JDBC连接Oracle数据库时，如何向数据库中写日期型数据（格式）？谢了！
  • jsp连接sql server2000数据库，用odbc、jdbc那种方案比较好！
  • Linux下，jdbc怎么连接Sybase数据库啊？
  • jsp连接数据库？？？？如何不使用jdbc and odbc??
  • 不想通过jdbc-odbc桥，连接数据库，该怎么做？
  • 如何用jdbc连接sybase数据库！
  • 如何用SQLServer2k-JDBC连接数据库？
  • java如何用jdbc连sybase数据库 iis7站长之家
  • java如何用jdbc连sybase数据库
  • 讨论：jdbc连接oracle数据库
  • JDBC连接SQLServer数据库问题!!!
  • 在jsp中通过JDBC和odbc链接数据库的语句各是怎样写的？
  • 关于JDBC与数据库的连接
  • Myeclipse中自带Tomcat的JDBC连接池配置(mysql和mssql)
  • 高性能JDBC驱动 DataDirect JDBC Drivers
  • 关于JDBC-ODBC和JDBC的区别
  • JDBC驱动代理 HA-JDBC
  • 访问MS SQL能不能直接用JDBC,如果能相应的JDBC Driver从哪里得到?
  • easy question:jdbc与jdk需要分别安装吗。如何设置jdbc的classpath
  • JDBC 工具包 Midao JDBC
  • 请问JDBC和JDBC-ODBC有什么区别？是不是连接的时候也有所不同。
  • JDBC 驱动程序 Drizzle-JDBC
  • JDBC执行日志 JDBC Logger


    • 站内导航:


    特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除！

    ©2012-2021,,E-mail:www_#163.com(请将#改为@)

    浙ICP备11055608号-3