JDBC系列：（2）使用Statement执行sql语句

shenzhang

package com.rk.db.b_statement;　　

　　
import java.sql.DriverManager;
　　
import java.sql.Connection;
　　
import java.sql.SQLException;
　　
import java.sql.Statement;
　　
import java.sql.ResultSet;
　　

　　
/**
　　
* 使用Statement执行DQL语句（查询操作）
　　
* @author RK
　　
*
　　
*/
　　
public class Demo03
　　
{
　　static
　　{
　　try
　　{
　　//1.驱动注册程序
　　Class.forName("com.mysql.jdbc.Driver");
　　}
　　catch (ClassNotFoundException e)
　　{
　　throw new RuntimeException(e);
　　}
　　}
　　public static void main(String[] args)
　　{
　　Connection conn = null;
　　Statement stmt = null;
　　ResultSet rs = null;
　　String url = "jdbc:mysql://localhost:3306/testdb";
　　String user = "root";
　　String password = "root";
　　try
　　{
　　//2.获取连接对象
　　conn = DriverManager.getConnection(url, user, password);
　　//3.创建Statement
　　stmt = conn.createStatement();
　　//4.准备sql
　　String sql = "SELECT * FROM T_Persons";
　　//5.发送sql语句，执行sql语句,得到返回结果
　　rs = stmt.executeQuery(sql);
　　//6.输出
　　while(rs.next())
　　{
　　int id = rs.getInt("Id");
　　String userName = rs.getString("UserName");
　　String pwd = rs.getString("Pwd");
　　System.out.println(id + "\t" + userName + "\t" + pwd);
　　}
　　}
　　catch (SQLException e)
　　{
　　e.printStackTrace();
　　}
　　finally
　　{
　　closeQuietly(rs);
　　closeQuietly(stmt);
　　closeQuietly(conn);
　　}
　　}
　　

　　/**
　　* 安静的关闭
　　*/
　　private static void closeQuietly(AutoCloseable ac)
　　{
　　if(ac != null)
　　{
　　try
　　{
　　ac.close();
　　}
　　catch (Exception e)
　　{
　　e.printStackTrace();
　　}
　　}
　　}
　　
}