JDBC数据库常用操作(mysql)

JDBC
英文名称:JavaDataBaseConnectivity
中文名称:java数据库连接
简称:JDBC
JDBC是一种用于执行SQL语句的JavaAPI,
可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准,据此可以构建更高级的工具和接口,使数据库开发人员能够编写数据库应用
程序。

一、建立数据库连接

1、引用jar文件(http://dev.mysql.com/downloads/connector/j/ 下载jar文件)

2、注册驱动Class.forName(“com.mysql.jdbc.Driver”)(只需注册一次)

3、定义数据库连接字符串URL="jdbc:mysql://127.0.0.1:3306/数据库名称?user=用户名&password=密码&useUnicode=true&characterEncoding=utf-8";

  JDBC:子协议:子名称//主机名:端口/数据库名?属性名=属性值&…
  user:用户名
  password:密码
  useUnicode:是否使用Unicode字符集,如果参数characterEncoding设置为gb2312或gbk,本参数值必须设置为true
  characterEncoding:当useUnicode设置为true时,指定字符编码。比如可设置为gb2312或gbk
  autoReconnect:当数据库连接异常中断时,是否自动重新连接。(默认:false)
  autoReconnectForPools:是否使用针对数据库连接池的重连策略。(默认:false)
  failOverReadOnly:自动重连成功后,连接是否设置为只读。(默认:true)
  maxReconnects:autoReconnect设置为true时,重试连接的次数 (默认3:)
  initialTimeout:autoReconnect设置为true时,两次重连之间的时间间隔,单位:秒 2
  connectTimeout:和数据库服务器建立socket连接时的超时,单位:毫秒。 0表示永不超时,适用于JDK 1.4及更高版本 0
  socketTimeout:socket操作(读写)超时,单位:毫秒。 0表示永不超时

二、常用数据库操作

  //数据库连接字符串
    publicstaticfinalStringDRIVER="com.mysql.jdbc.Driver";
    publicstaticfinalStringURL="jdbc:mysql://127.0.0.1:3306/MyLibrary?user=root&password=123456&useUnicode=true&characterEncoding=utf-8";

1、添加数据

    publicstaticvoidinsert()throwsSQLException{
        Connectioncon=null;
        Statementst=null;
        try{
            Class.forName(DRIVER);
            con=DriverManager.getConnection(URL);
            st=con.createStatement();
            st.execute("insertintoarticle(title)values(‘标题‘);");
        }catch(ClassNotFoundExceptione){
            e.printStackTrace();
        }finally{
            con.close();
            st.close();
        }
    }

2、删除数据

    publicstaticvoiddelete(intid)throwsSQLException{
        Connectioncon=null;
        Statementst=null;
        try{
            Class.forName(DRIVER);
            con=DriverManager.getConnection(URL);
            st=con.createStatement();
            st.executeUpdate("deletefromarticlewhereid="+id+";");
        }catch(ClassNotFoundExceptione){
            e.printStackTrace();
        }finally{
            con.close();
            st.close();
        }
    }

3、修改数据

    publicstaticvoidupdate()throwsSQLException{
        Connectioncon=DriverManager.getConnection(URL);
        Statementst=con.createStatement();
        st.executeUpdate("updatearticlesettitle=‘新标题‘whereid=1;");
        con.close();
        st.close();
    }

4、查询数据

    publicstaticvoidselect()throwsSQLException{
        Connectioncon=null;
        Statementst=null;
        try{
            Class.forName(DRIVER);
            con=DriverManager.getConnection(URL);
            st=con.createStatement();
            ResultSetrs=st.executeQuery("select*fromarticle;");
            while(rs.next()){
                System.out.print(rs.getInt("id"));
                System.out.println(rs.getString("title"));
            }
            //按表结构自动输出
//            ResultSetMetaDatarsmd=rs.getMetaData();
//            for(inti=1;i<rsmd.getColumnCount();i++){
//                System.out.print(rsmd.getColumnName(i));
//                System.out.println(rsmd.getColumnTypeName(i));
//            }
        }catch(ClassNotFoundExceptione){
            e.printStackTrace();
        }finally{
            st.close();
            con.close();
        }
    }

5、参数预处理

    publicstaticvoidinsert(Stringtitle)throwsSQLException{
        Connectioncon=DriverManager.getConnection(URL);
        PreparedStatementpst=con.prepareStatement("insertintoarticle(title)values(?);");
        pst.setString(1,title);
        pst.executeUpdate();
        con.close();
        pst.close();
    }

6、批处理

    publicstaticvoidinsertBatch(String[]title)throwsSQLException{
//        Connectioncon=DriverManager.getConnection(URL);
//        Statementst=con.createStatement();
//        for(inti=0;i<title.length;i++){
//            st.addBatch("insertintoarticle(title)values(‘"+title[i]+"‘);");
//        }
//        st.executeBatch();        
//        con.close();
//        st.close();
        
        //参数预处理+批处理
        Connectioncon=DriverManager.getConnection(URL);
        PreparedStatementpst=con.prepareStatement("insertintoarticle(title)values(?);");
        for(inti=0;i<title.length;i++){
            pst.setString(1,title[i]);
            pst.addBatch();
        }
        pst.executeBatch();
        con.close();
        pst.close();
    }

7、事务操作

  7.1、数据库事务的特性:
    原子性(atomicity):一个事务是一个不可分割的工作单位,事务中包括的操作要么都做,要么都不做。
    一致性(consistency):事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。
    隔离性(isolation):一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰。
    持久性(durability):持续性也称永久性(permanence),指一个事务一旦提交,它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。
  7.2、JDBC事务操作
  (1)setAutoCommit(Booleanauto Commit):设置是否自动提交事务;
  (2)commit():提交事务;
  (3)rollback():撤消事务;
    默认的情况为自动提交事务,也就是说,每一条对数据库的更新的sql语句代表一项事务,操作成功后,系统自动调用commit()来提交,否则将调用rollback()来撤消事务。在jdbc中,可以通过调用setAutoCommit(false)来禁止自动提交事务。然后就可以把多条更新数据库的sql语句做为一个事务,在所有操作完成之后,调用commit()来进行整体提交。倘若其中一项sql操作失败,就不会执行commit()方法,而是产生相应的sqlexception,此时就可以捕获异常代码块中调用rollback()方法撤消事务。

    publicstaticvoidtransaction()throwsSQLException{
        Connectioncon=DriverManager.getConnection(URL);
        Statementst=con.createStatement();
        try{
            con.setAutoCommit(false);//更改JDBC事务的默认提交方式
            st.executeUpdate("deletefromarticlewhereid=1;");
            st.executeUpdate("deletefromarticlewhereid=2;");
            con.commit();//提交JDBC事务
            con.setAutoCommit(true);//恢复JDBC事务的默认提交方式
        }catch(Exceptionexc){
            con.rollback();//回滚JDBC事务
        }finally{
            st.close();
            con.close();
        }
    }

8、调用mysql存储过程

    publicstaticvoidcallProcedure()throwsSQLException{
        Connectioncon=DriverManager.getConnection(URL);
        CallableStatementcst=con.prepareCall("{callproc_select(?)}");
     //传入参数值 cst.setInt(
1,3); //如果第一个结果是ResultSet对象,则返回true;如果第一个结果是更新、添加、修改或者没有结果,则返回false booleanissuccess=cst.execute(); //成功返回true,失败返回false System.out.println(issuccess); }

三、JDBC执行sql语句方法

  1、executeQuery(String sql): 执行SQL查询,并返回ResultSet 对象。

  2、executeUpdate(String sql): 可执行增,删,改,返回执行受到影响的行数。

  3、execute(String sql);:可执行任何SQL语句,返回一个布尔值,表示是否返回ResultSet 。

四、JDBC Statement类型

  1、Statement:接口提供了执行语句和获取结果的基本方法,用于执行不带参数的简单SQL语句,每次执行sql语句,数据库都要执行sql语句的编译,最好用于仅执行一次查询并返回结果的情形,效率高于PreparedStatement。

  2、PrepareStatement:可变参数的SQL,编译一次,执行多次,效率高;安全性好,有效防止Sql注入等问题;支持批量更新,批量删除;执行的SQL语句中是可以带参数的,并支持批量执行SQL。由于采用Cache机制,则预先编译的语句,就会放在Cache中,下次执行相同SQL语句时,则可以直接从Cache中取出来。

  3、CallableStatement:用于执行对数据库已存储过程的调用,继承自PreparedStatement,支持带参SQL操作;支持调用存储过程,提供了对输出和输入/输出参数的支持;
在JDBC中调用存储过程的语法如下所示:
  {call过程名[(?,?)]}
  返回结果参数的过程的语法为:
  {?=call过程名[(?,?,...)]}
  不带参数的存储过程的语法类似:
  {call过程名}
  CallableStatement中定义的所有方法都用于处理OUT参数或INOUT参数的输出部分:注册OUT参数的JDBC类型(一般SQL类型)、从这些参数中检索结果,或者检查所返回的值是否为JDBCNULL。

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。