JDBC 调用存储过程

copyking

数据库连接池：
   数据库连接不仅仅是在应用服务器与数据库之间建立一个Socket Connection，连接建立之后，还需要交换若干次数据（比如验证用户密码，权限等），然后，数据库开始初始化连接会话句柄，记录联机日志，为此连接分配相应的处理进程和系统资源。系统如此繁忙，如果我们只是简单的扔过去两个SQL语句，然后就将此连接抛弃，实在可惜，数据库连接池正是解决了这个问题。其基本原理就是在内部对象池中维护一定数量的数据库连接，并对外暴露数据库连接获取和返回的方法。

下面用几个小例子来讨论一下最常用的几个DataSource：
先建一个jdbc.properties属性文件：
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql:///it315
username=root
password=
再建一个XML配置文件，这里面有三种方法可以获取DataSource，包括Jakarta的BasicDataSource,ibatis的SimpleDataSource和Spring自带的DriverManagerDataSource：
http://www.springframework.org/dtd/spring-beans.dtd
">


  
   jdbc.properties
  



  
  ${driverClassName}
  
  
  ${url}
  
  
  ${username}
  
  
  ${password}
  
  


  
  
  ${driverClassName}
  ${url}
  ${username}
  ${password}
  
  
  
-->


  
   ${driverClassName}
  
  
   ${url}
  
  
   ${username}
  
  
   ${password}
  

再建一个使用此连接池的测试类，这个类的代码几乎可以固定，要用不同的连接池只要改上面的XML文件就行了，运行结果都是一样的：
package cn.it315;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.sql.DataSource;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class DataSourceExample {
public void showAll() {
  Connection conn = null;
  PreparedStatement pstmt = null;
  DataSource ds = null;
  ResultSet rs = null;
  String sql = "select * from student";
  ApplicationContext application = new ClassPathXmlApplicationContext(
    "/applicationContext.xml");
  try {
   ds = (DataSource) application.getBean("dataSource");//从配置文件中读取出一个DataSource
   conn = ds.getConnection();
   pstmt = conn.prepareStatement(sql);
   rs = pstmt.executeQuery();
   System.out.println("ID\tName\tAddress\n");
   while (rs.next()) {
    System.out.println(rs.getInt(1) + "\t" + rs.getString(2) + "\t"
      + rs.getString(3));
   }
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   if (rs != null)
    try {
     rs.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
   if (pstmt != null)
    try {
     pstmt.close();
    } catch (SQLException e1) {
     e1.printStackTrace();
    }
   if (conn != null)
    try {
     conn.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
  }
}
public static void main(String[] args) {
  DataSourceExample ds = new DataSourceExample();
  ds.showAll();
}
}
上面是用XML配置文件获取数据库连接池的方法。下面再介绍两种手工写代码的方法，当然我们还是用读属性文件的方式：
首先得有一个属性文件，这里用的就是上面那个jdbc.properties.
再写一个类来获取数据库连接池并使用它，这里用的是BasicDataSourceFactory：
package cn.itcast;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
public class DataSourceExample {
public Properties getProps() {
  Properties props = new Properties();
  InputStream ips = this.getClass()
    .getResourceAsStream("jdbc.properties");
  try {
   props.load(ips);
  } catch (IOException e) {
   e.printStackTrace();
  } finally {
   if (ips != null)
    try {
     ips.close();
    } catch (IOException e) {
     e.printStackTrace();
    }
  }
  return props;
}
public void showAll() {
  Properties props = getProps();
  Connection conn = null;
  PreparedStatement pstmt = null;
  ResultSet rs = null;
  String sql = "select * from student";
  DataSource dataSource = null;
  try {
   // 使用BasicDataSourceFactory获取数据源
   dataSource = BasicDataSourceFactory.createDataSource(props);
   conn = dataSource.getConnection();
   pstmt = conn.prepareStatement(sql);
   rs = pstmt.executeQuery();
   System.out.println("ID\tName\tAddress\n");
   while (rs.next()) {
    System.out.println(rs.getInt(1) + "\t" + rs.getString(2) + "\t"
      + rs.getString(3));
   }
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   if (rs != null)
    try {
     rs.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
   if (pstmt != null)
    try {
     pstmt.close();
    } catch (SQLException e1) {
     e1.printStackTrace();
    }
   if (conn != null)
    try {
     conn.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
  }
}
public static void main(String[] args) {
  DataSourceExample ds = new DataSourceExample();
  ds.showAll();
}
}
再看一个Hibernate的DriverManagerConnectionProvider获取数据库连接池的方法：
package cn.itcast;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
import org.hibernate.connection.DriverManagerConnectionProvider;
public class DataSourceExample {
public Properties getProps() {
  Properties props = new Properties();
  InputStream ips = this.getClass().getResourceAsStream(
    "hibernate.properties");
  try {
   props.load(ips);
  } catch (IOException e) {
   e.printStackTrace();
  } finally {
   if (ips != null)
    try {
     ips.close();
    } catch (IOException e) {
     e.printStackTrace();
    }
  }
  return props;
}
public void showAll() {
  Properties props = getProps();
  Connection conn = null;
  PreparedStatement pstmt = null;
  ResultSet rs = null;
  String sql = "select * from student";
  DriverManagerConnectionProvider dataSource = new DriverManagerConnectionProvider();
  try {
   dataSource.configure(props);
   conn = dataSource.getConnection();
   pstmt = conn.prepareStatement(sql);
   rs = pstmt.executeQuery();
   System.out.println("ID\tName\tAddress\n");
   while (rs.next()) {
    System.out.println(rs.getInt(1) + "\t" + rs.getString(2) + "\t"
      + rs.getString(3));
   }
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   if (rs != null)
    try {
     rs.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
   if (pstmt != null)
    try {
     pstmt.close();
    } catch (SQLException e1) {
     e1.printStackTrace();
    }
   if (conn != null)
    try {
     conn.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
  }
}
public static void main(String[] args) {
  DataSourceExample ds = new DataSourceExample();
  ds.showAll();
}
}
这几种方法的运行结果都是一样的。
使用CallableStatement调用存储过程，我们也用小例子来学习：
package cn.itcast;
import javax.sql.DataSource;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
public class MainClass {

//获取一个连接。现学现用，我们这里就用上面从数据库连接池获取连接的方法。
//配置文件和属性文件这里就省略不写了，参考上面的例子：
public static Connection getConnection() throws SQLException {
  ApplicationContext application = new ClassPathXmlApplicationContext(
    "/applicationContext.xml");
  DataSource ds = (DataSource) application.getBean("dataSource");//从配置文件中读取出一个DataSource
  return ds.getConnection();
}
public static void main(String[] args) {
  Connection conn = null;
  CallableStatement cstmt = null;
  ResultSet rs = null;
  try {
   conn = getConnection();
   // 调用mySql函数,用这种方式：{返回值=call 函数名(参数列表)}
   /*
     cstmt = conn.prepareCall("{?=call getName(?,?)}");
     //注册输出参数，这里是代表第一个问号。这里要注意，第一个参数的索引也是1。
     cstmt.registerOutParameter(1,Types.VARCHAR);
     
     cstmt.setInt(1,1);//设置第一个参数的值，注意：是第一个参数，并不是第一个问号,在这里是第二个问号
     cstmt.setString(2,"a");//设置第二个参数的值。
     cstmt.execute();
     System.out.println(cstmt.getString(1));
   */
   // 调用mysql存储过程，这种格式：{call 存储过程名(参数列表(包括输出和输入参数))}
   cstmt = conn.prepareCall("{call search(?,?,?)}");
   cstmt.setInt(3, 4);
   //设置第三个问号的值，因为这个参数是输入参数。其他两个是输出参数。
   //我们在下面用getXxx()的方法获取出来。
   cstmt.execute();//执行
   System.out.println("Name = " + cstmt.getString(1));//获取第一个输出参数
   System.out.println("Address = " + cstmt.getString(2));//获取第二个输出参数
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   if (rs != null)
    try {
     rs.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
   if (cstmt != null)
    try {
     cstmt.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
   if (conn != null)
    try {
     conn.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
  }
}
}

本文来自ChinaUnix博客，如果查看原文请点：http://blog.chinaunix.net/u2/66684/showart_1743497.html