jdbc初步（转）

1. Jdbc的六个编程步骤

1. 注册一个驱动

注册驱动程序有三种方式：

方式一：Class.forName(“oracle.jdbc.driver.OracleDriver”);

JAVA 规范中明确规定：所有的驱动程序必须在静态初始化代码块中将驱动

注册到驱动程序管理器中。

方式二：Driver drv = new oracle.jdbc.driver.OracleDriver();

DriverManager.registerDriver(drv);

方式三：编译时在虚拟机中加载驱动

javac –Djdbc.drivers = oracle.jdbc.driver.OracleDriver xxx.java

java –D jdbc.drivers=驱动全名 类名

使用系统属性名，加载驱动 -D 表示为系统属性赋值

附 : mysql 的 Driver 的全名 com.mysql.jdbc.Driver

SQLServer 的 Driver 的全名 com.microsoft.jdbc.sqlserver.SQLServerDriver

2. 取得一个连接

Conn = DriverManager.getConnection(jdbcURL,userName,password);

3. 获得一个Statement声明对象

Statement st = conn.createStatement();

PreparedStatement ps = conn.prepareStatement(sql);

CallableStatemetn cs = conn.prepareCall(sql);

4. 通过Statement对象执行Sql语句

sta.execute(String sql); 如果返回一个结果集则返回true,否则返回false。

sta.executeQuery(String sql);返回一个查询结果集。

sta.executeUpdate(String sql);返回值为 int 型，表示影响记录的条数。

将 sql 语句通过连接发送到数据库中执行，以实现对数据库的操作。

5. 若有结果集ResultSet则处理结果集

ResultSetMetaDate rsmd = rs.getMetaData();

int columnCount = rsmd.getColumnCount();

While(rs.next()){

for(int i = 1; i <= columnCount; i++)

{

if(i != 1) System.out.print(",");

String name = rsmd.getColumnName(i); //取得第i列的列名称

String value = rs.getString(i); //取得第i列的值

System.out.print(name + "=" + value);

}

}

6. 关闭资源

2. 第一个Jdbc程序

[java] view plaincopyprint?

  1. public class AccountDaoBad
  2. {
  3. public void select()
  4. {
  5. Connection con = null;
  6. Statement st = null;
  7. ResultSet rs = null;
  8. try
  9. {
  10. Class.forName("oracle.jdbc.driver.OracleDriver");
  11. /** static init block in OracleDriver*/
  12. String jdbcURL = “jdbc:oracle:thin:@192.168.0.5:1521:tarena”;
  13. con = DriverManager.getConnection(jdbcURL, "sd0703", "sd0703");
  14. st = con.createStatement();
  15. System.out.println(st.getFetchSize());
  16. String sql = "select id,no,owner,pwd,cdate,balance from sd0703_account";
  17. rs = st.executeQuery(sql);
  18. while(rs.next())
  19. {
  20. System.out.print("id=" + rs.getInt(1));
  21. System.out.print(",no=" + rs.getString(2));
  22. System.out.print(",owner=" + rs.getString(3));
  23. System.out.print(",pwd=" + rs.getString(4));
  24. System.out.print(",cdate=" + rs.getDate(5));
  25. System.out.println(",balance=" + rs.getDouble(6));
  26. }
  27. }catch(SQLException e)
  28. {
  29. e.printStackTrace();
  30. throw new RuntimeException(e.getMessage());
  31. }catch(ClassNotFoundException e)
  32. {
  33. e.printStackTrace();
  34. throw new RuntimeException(e.getMessege());
  35. }finally
  36. {
  37. try{ con.close();}catch(Exception e) {e.printStatckTrace();}
  38. }
  39. }
public class AccountDaoBad
{
    public void select()
    {
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;

        try
        {
            Class.forName("oracle.jdbc.driver.OracleDriver");
            /** static init block in OracleDriver*/
String jdbcURL = “jdbc:oracle:thin:@192.168.0.5:1521:tarena”;
            con = DriverManager.getConnection(jdbcURL, "sd0703", "sd0703");
            st = con.createStatement();
            System.out.println(st.getFetchSize());
            String sql = "select id,no,owner,pwd,cdate,balance from sd0703_account";
            rs = st.executeQuery(sql);
            while(rs.next())
            {
                System.out.print("id=" + rs.getInt(1));
                System.out.print(",no=" + rs.getString(2));
                System.out.print(",owner=" + rs.getString(3));
                System.out.print(",pwd=" + rs.getString(4));
                System.out.print(",cdate=" + rs.getDate(5));
                System.out.println(",balance=" + rs.getDouble(6));
            }
        }catch(SQLException e)
        {
            e.printStackTrace();
            throw new RuntimeException(e.getMessage());

        }catch(ClassNotFoundException e)
        {
            e.printStackTrace();
            throw new RuntimeException(e.getMessege());

        }finally
        {
            try{ con.close();}catch(Exception e) {e.printStatckTrace();}
        }
    }

3. 常用类

1. Connection, Statement, ResultSet,

4. 2.0新特性

(1)事务管理与图片的存储

[java] view plaincopyprint?

  1. public class ImageLibraryService
  2. {
  3. public void addImage(long id, String imageName, String path) throws SQLException
  4. {
  5. Connection con = null;
  6. PreparedStatement ps = null;
  7. ResultSet rs = null;
  8. try
  9. {
  10. con = ConnectionFactory.getConnection();
  11. con.setAutoCommit(false);
  12. String sql = "insert into ImageLibrary(id, name, image)";
  13. sql += " VALUES(?, ?, empty_blob())";
  14. ps = con.prepareStatement(sql);
  15. ps.setLong(1, id);
  16. ps.setString(2, imageName);
  17. ps.executeUpdate();
  18. ps.close();
  19. ps = con.prepareStatement("select image from ImageLibrary WHERE id = ? for update ");
  20. ps.setLong(1, id);
  21. rs = ps.executeQuery();
  22. if (rs.next())
  23. {
  24. Blob image = rs.getBlob(1);
  25. OutputStream out = image.setBinaryStream(0);
  26. BufferedOutputStream bufferedOut = new BufferedOutputStream(out);
  27. BufferedInputStream bufferedIn = new BufferedInputStream(new FileInputStream(path));
  28. int c;
  29. while ((c = bufferedIn.read()) != -1)
  30. {
  31. bufferedOut.write(c);
  32. }
  33. bufferedIn.close();
  34. bufferedOut.close();
  35. }
  36. con.commit();
  37. } catch (Exception e)
  38. {
  39. e.printStackTrace();
  40. try
  41. {
  42. con.rollback();
  43. } catch (SQLException se) { }
  44. throw new SQLException(e.getMessage());
  45. } finally
  46. {
  47. JdbcUtil.close(rs, ps, con);
  48. }
  49. }
  50. //以下代码没有进行细致的异常捕获
  51. public void restoreImage(long id, String filename) throws Exception
  52. {
  53. Connection con = ConnectionFactory.getConnection();
  54. Statement st = con.createStatement();
  55. String sql = "SELECT image From ImageLibrary Where id = " + id;
  56. ResultSet rs = st.executeQuery(sql);
  57. while (rs.next())
  58. {
  59. Blob image = rs.getBlob("image");
  60. BufferedOutputStream out = new BufferedOutputStream(new FileOutputStream(filename));
  61. BufferedInputStream in = new BufferedInputStream(image.getBinaryStream());
  62. int c;
  63. while ((c = in.read()) != -1) out.write(c);
  64. in.close();
  65. out.close();
  66. }
  67. }
  68. }
public class ImageLibraryService
{
    public void addImage(long id, String imageName, String path) throws SQLException
    {
        Connection con = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try
        {
            con = ConnectionFactory.getConnection();
            con.setAutoCommit(false);
            String sql = "insert into ImageLibrary(id, name, image)";
            sql += " VALUES(?, ?, empty_blob())";
            ps = con.prepareStatement(sql);
            ps.setLong(1, id);
            ps.setString(2, imageName);
            ps.executeUpdate();
            ps.close();
            ps = con.prepareStatement("select image from ImageLibrary WHERE id = ? for update ");
            ps.setLong(1, id);
            rs = ps.executeQuery();
            if (rs.next())
            {
                Blob image = rs.getBlob(1);
                OutputStream out = image.setBinaryStream(0);
                BufferedOutputStream bufferedOut = new BufferedOutputStream(out);
                BufferedInputStream bufferedIn = new BufferedInputStream(new FileInputStream(path));
                int c;
                while ((c = bufferedIn.read()) != -1)
                {
                    bufferedOut.write(c);
                }
                bufferedIn.close();
                bufferedOut.close();
            }
            con.commit();
        } catch (Exception e)
        {
            e.printStackTrace();
            try
            {
                con.rollback();
            } catch (SQLException se)  {    }
            throw new SQLException(e.getMessage());
        } finally
        {
            JdbcUtil.close(rs, ps, con);
        }
    }
//以下代码没有进行细致的异常捕获
    public void restoreImage(long id, String filename) throws  Exception
    {
        Connection con = ConnectionFactory.getConnection();
        Statement  st = con.createStatement();
String sql = "SELECT image  From ImageLibrary Where id = " + id;
        ResultSet rs = st.executeQuery(sql);
        while (rs.next())
        {
           Blob image = rs.getBlob("image");
           BufferedOutputStream out = new BufferedOutputStream(new FileOutputStream(filename));
            BufferedInputStream in = new BufferedInputStream(image.getBinaryStream());
           int c;
           while ((c = in.read()) != -1)   out.write(c);
           in.close();
           out.close();
        }
    }
}

(2)结果集游标的上下游动

[java] view plaincopyprint?

  1. con = ConnectionFactory.getConnection();
  2. st = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
  3. String sql = "select id,no,owner,pwd,cdate,balance from sd0703_account";
  4. rs = st.executeQuery(sql);
  5. rs.afterLast(); //将光标移动到此 ResultSet 对象的末尾，正好位于最后一行之后。
  6. while(rs.previous())
  7. {
  8. System.out.print("id=" + rs.getInt(1));
  9. System.out.print(",no=" + rs.getString(2));
  10. System.out.print(",owner=" + rs.getString(3));
  11. System.out.print(",pwd=" + rs.getString(4));
  12. System.out.print(",cdate=" + rs.getDate(5));
  13. System.out.println(",balance=" + rs.getDouble(6));
  14. }
con = ConnectionFactory.getConnection();
st = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
String sql = "select id,no,owner,pwd,cdate,balance from sd0703_account";
rs = st.executeQuery(sql);
rs.afterLast(); //将光标移动到此 ResultSet 对象的末尾，正好位于最后一行之后。
while(rs.previous())
{
     System.out.print("id=" + rs.getInt(1));
     System.out.print(",no=" + rs.getString(2));
     System.out.print(",owner=" + rs.getString(3));
     System.out.print(",pwd=" + rs.getString(4));
     System.out.print(",cdate=" + rs.getDate(5));
     System.out.println(",balance=" + rs.getDouble(6));
}

注：ResultSet静态常量字段(参见javax.sql.ResultSet)

ResultSet.TYPE_SCROLL_INSENSITIVE

该常量指示可滚动但通常不受 ResultSet 底层数据更改影响的 ResultSet 对象的类型。

ResultSet.CONCUR_READ_ONLY

该常量指示不可以更新的 ResultSet 对象的并发模式。

http://www.cnblogs.com/smileallen/archive/2013/02/16/3391573.html

时间： 2024-11-03 03:25:53

jdbc初步（转）的相关文章

JDBC初步

JDBC 1 import java.sql.*; 2 3 public class TestJDBC { 4 public static void main(String[] args) { 5 ResultSet rs = null; 6 Statement stmt = null; 7 Connection conn = null; 8 try { 9 // Class是java.lang的包, 给名子把类的实例new出来 可能找不到类 抛异常ClassNotFoundException

jMeter的初步学习--连接jdbc（转）

jmeter是纯java的写的一个既可以用于功能测试也可以用于压力测试的一款东东.他不仅可以测试web 也可以测试DB,最近的项目用到了连接JDBC的情况: 注意点: (1) 需要将要连接的数据库的jdbc driver放到jmeter的lib中. 场景:使用jmeter对web应用和mysql数据库进行压力测试 JMeter是一款非常强大的测试工具,可以用来测试web,数据库,从07年用过之后一直对它情有独钟,下面记录下在一个项目中对它的简单使用. 项目分数据库测试和web应用测试 数据库测试

JDBC的初步了解及使用

一.概念 1.什么是JDBC? JDBC(Java Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成.JDBC提供了一种基准,据 此可以构建更高级的工具和接口,使数据库开发者能够编写数据库的程序.简单地说,JDBC 可做三件事:与数据库建立连接.发送 操作数据库的语句并处理结果. 2.JDBC有什么用呢? 我们用JAVA就能连接到数据库:创建SQL或者MYSQL

JDBC第四次学习

传智播客李勇老师的JDBC系列学习终于接近尾声了,好开心,能学到这么多的东西,还不赶快记录下来,留待以后回味! 如何使用开源项目DBCP(实际项目中常用)    主要分为三个步骤: 使用DBCP必须用的jar包. 添加dbcp的配置文件. Java API:BasicDataSourceFactory.createDataSource(prop); 不然会报异常: java.lang.ClassNotFoundException: org.apache.commons.logging.LogFa

DAO设计模式实现数据库的增删改查（进一步封装JDBC工具类）

一.DAO模式简介 DAO即Data Access Object,数据访问接口.数据访问:故名思义就是与数据库打交道.夹在业务逻辑与数据库资源中间. DAO模式实际上是两个模式的组合,即Data Accessor (数据访问者)模式和 Active Domain Object(领域对象)模式.Data Accessor 模式实现了数据访问和业务逻辑的分离:Active Domain Object 模式实现了业务数据的对象化封装. 需要注意的是,DAO设计模式是Java EE中的设计模式,而非Ja

JDBC基本使用

J2EE技术规范(二)--JDBC 分类: java2012-12-03 14:25 1060人阅读 评论(8) 收藏 举报 一.了解JDBC (1) JDBC是以统一方式访问数据库的API (2) JDBC提供: 独立于平台的数据库访问 位置透明 对专有数据库的问题时透明的 二.了解JDBC驱动程序 (1) JDBC Drivers是实现数据库操作的类 (2) Drivers分成两类: 2-层--客户直接和数据库会话 3-层--客户与代表数据库的中间层(WebLogic Server)会话 其

com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: Data source rejected establishment of connection, message from server: &quot;Too many connections&quot;

最简单的办法是因为你的my.ini中设定的并发连接数太少或者系统繁忙导致连接数被占满解决方式:打开MySQL安装目录打开MY.INI找到max_connections默认是100 .--实例 WINDOWS解决mysql Errno.: 1040错误XXXX info: Can not connect to MySQL server User: rootTime: 2004-5-20 3:00pmScript: /XXXX/XXXX.PHP Error: Too many connections

JAVA之JDBC的简单使用(Mysql)

JDBC增删查改 昨天七七八八的关于Mysql的配置 和 基本使用也算是初步解决了,今天 抽空看了JAVA的JDBC(JAVA DATA BASE CONNECTION)我也不知道我全称拼写对对不对??,笔者英文水平太渣渣. 具体的关于解释jdbc的东东在本文就不阐述了,网上百度一大堆,本文主要记录 实现过程 中的关键点和小坑. 首先 就要把这个问题的解决方法给抛出来 PreparedStatement  的占位符使用 : PreparedStatement是Statement的改良版,具有预编

谷哥的小弟学后台(06)——JDBC

探索Android软键盘的疑难杂症 深入探讨Android异步精髓Handler 详解Android主流框架不可或缺的基石 站在源码的肩膀上全解Scroller工作机制 Android多分辨率适配框架(1)- 核心基础 Android多分辨率适配框架(2)- 原理剖析 Android多分辨率适配框架(3)- 使用指南 自定义View系列教程00–推翻自己和过往,重学自定义View 自定义View系列教程01–常用工具介绍 自定义View系列教程02–onMeasure源码详尽分析 自定义View