Java数据库操作库DButils类的使用方法与实例详解

  create table stuInfo 
 ( 
  stuNo int primary key identity (1,1),--学号 
  stuName nvarchar(10) not null,--学生姓名 
  stuSex nvarchar(2) not null,--学生性别 
  stuAge int not null,--学生年龄 
  stuSeat int not null,--学生座位 
  stuAddress nvarchar(20) --学生住址  
 )

public class QueryRunnerTest { 
 public static void main(String[] args) { 
  QueryRunnerTest test = new QueryRunnerTest(); 
  test.add(); 
  test.delete(); 
  test.update(); 
  test.find(); 
  test.getAll(); 

 } 
 //静态方法获取数据库链接对象：
 private static Connection getConnection() { 
  Connection conn = null; 
  try {   Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); conn = DriverManager.getConnection("jdbc:sqlserver://localhost:1433;Database=student", "sa", "sasa"); 
  } catch (SQLException e) { 
   e.printStackTrace(); 
  } catch (ClassNotFoundException e) { 
   e.printStackTrace(); 
  } 
  System.out.println(conn); 
  return conn; 
 } 

 //添加方法 
 public void add () { 
  Connection conn = getConnection(); 
  QueryRunner qr = new QueryRunner(); 
  String sql = "insert into stuInfo (stuName,stuSex,stuAge,stuSeat,stuAddress) values (?,?,?,?,?)"; 
  Object param[] = {"张良","男",20,11,"韩国"}; 
  int i; 
  try { 
   i = qr.update(conn, sql, param); //i是受操作影响的行数；
   System.out.println("添加成功："+i); 
   DbUtils.closeQuietly(conn); //关闭链接； 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
 } 
 //删除方法 
 public void delete() { 
  Connection conn = getConnection(); 
  QueryRunner qr = new QueryRunner(); 
  String sql ="delete from stuInfo where stuNo=?"; 
  try { 
   int i = qr.update(conn, sql, 7); i是受操作影响的行数；
   System.out.println("删除成功："+i); 
   DbUtils.closeQuietly(conn); //关闭链接；  
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
 } 
 //修改方法 
 public void update() { 
  Connection conn = getConnection(); 
  QueryRunner qr = new QueryRunner(); 
  String sql = "update stuInfo set stuName=? where stuNo=?"; 
  Object params[] = {"胡歌",3}; 
  try { 
   int i = qr.update(conn, sql, params); 
   System.out.println("修改成功："+i); // i是受操作影响的行数；
   DbUtils.closeQuietly(conn); //关闭链接； 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
 } 
 //查询方法 
 public void find() { 
  Connection conn = getConnection(); 
  QueryRunner qr = new QueryRunner(); 
  String sql = "select * from stuInfo where stuNo=?"; 
  Object params[] = {5}; 
  try { 
   StuInfo stuInfo = (StuInfo)qr.query(conn, sql, new BeanHandler<StuInfo>(StuInfo.class), params); 
   System.out.println("查询成功："+stuInfo); 
   DbUtils.closeQuietly(conn); //关闭链接； 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
 }  
 //查询所有 
 public void getAll() { 
  Connection conn = getConnection(); 
  QueryRunner qr = new QueryRunner(); 
  String sql ="select * from stuInfo"; 
  ArrayList<StuInfo> list; 
  try { 
   list = (ArrayList<StuInfo>) qr.query(conn, sql, new BeanListHandler<StuInfo>(StuInfo.class)); 
   for (StuInfo stuInfo : list) { 
    System.out.println(stuInfo); 
   } 
   DbUtils.closeQuietly(conn); //关闭链接； 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 

 } 
} 

public class Demo2 {
 @Test
 public void test1() throws SQLException {
  QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
  String sql = "select * from users";
  Object[] result = runner.query(sql, new ArrayHandler());
  System.out.println(result[0]);
  System.out.println(result[1]);
 }
}

public class Demo2 {
 @Test
 public void test2() throws SQLException {
  QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
  String sql = "select * from users";
  List list = runner.query(sql, new ArrayListHandler());
  System.out.println(list);
 }
}

public class Demo2 {
 @Test
 public void test3() throws SQLException {
  QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
  String sql = "select * from users";
  List list = (List) runner.query(sql, new ColumnListHandler("name"));
  System.out.println(list);
 }
}

public class Demo2 {
 @Test
 public void test4() throws SQLException {
  QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
  String sql = "select * from users";
  Map<Integer, Map<String, Object>> map = (Map<Integer, Map<String, Object>>) runner.query(sql, new KeyedHandler("id"));
  for (Map.Entry<Integer, Map<String, Object>> me : map.entrySet()) {
   int id = me.getKey();
   for (Map.Entry<String, Object> entry : me.getValue().entrySet()) {
    String name = entry.getKey();
    Object value = entry.getValue();
    System.out.println(name+"="+value);
   }
  }
 }
}