最近看老罗的视频,跟着完成了利用Java操作MySql数据库的一个框架类JdbcUtils.java,完成对数据库的增删改查。其中查询这块,包括普通的查询和利用反射完成的查询,主要包括以下几个函数接口:
1、public Connection getConnection() 获得数据库的连接
2、public boolean updateByPreparedStatement(String sql, List
3、public Map findSimpleResult(String sql, List
4、public List
上面四个函数已经包括了MySQl的所有操作,完全能够满足使用需要。视频里老罗还扩展了两个反射来查询的函数。
5、public T findSimpleRefResult(String sql, List params,
6、 public List findMoreRefResult(String sql, List params,
下面附完整代码:
JdbcUtils.java
package com.jdbc.dbutils;
import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import domain.UserInfo;
public class JdbcUtils {
//数据库用户名
private static final String USERNAME = "root";
//数据库密码
private static final String PASSWORD = "yanzi";
//驱动信息
private static final String DRIVER = "com.mysql.jdbc.Driver";
//数据库地址
private static final String URL = "jdbc:mysql://localhost:3306/mydb";
private Connection connection;
private PreparedStatement pstmt;
private ResultSet resultSet;
public JdbcUtils() {
// TODO Auto-generated constructor stub
try{
Class.forName(DRIVER);
System.out.println("数据库连接成功!");
}catch(Exception e){
}
}
/**
* 获得数据库的连接
* @return
*/
public Connection getConnection(){
try {
connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return connection;
}
/**
* 增加、删除、改
* @param sql
* @param params
* @return
* @throws SQLException
*/
public boolean updateByPreparedStatement(String sql, Listparams)throws SQLException{
boolean flag = false;
int result = -1;
pstmt = connection.prepareStatement(sql);
int index = 1;
if(params != null && !params.isEmpty()){
for(int i=0; i 0 true : false;
return flag;
}
/**
* 查询单条记录
* @param sql
* @param params
* @return
* @throws SQLException
*/
public Map findSimpleResult(String sql, List params) throws SQLException{
Map map = new HashMap();
int index = 1;
pstmt = connection.prepareStatement(sql);
if(params != null && !params.isEmpty()){
for(int i=0; i> findModeResult(String sql, List params) throws SQLException{
List