使用的是MySQL數據庫，首先導入驅動類，然后根據數據庫URL和用戶名密碼獲得數據的鏈接。由于使用的是MySQL數據庫，它的URL一般為，jdbc：mysql：//主機地址：端口號/庫名。
下面是封裝的具體類，用到了泛型和反射，不過還存在些問題，就是對使用的泛型對象有些限制，只能用于泛型類對象屬性名與數據庫表中列名相同的對象，而且初始化對象的方法必須為set+屬性名的方法。本來想通過返回值類型，參數列表來確定該屬性初始化方法的，然而可能是目前學到的還是太少，只學了三周，所以并沒有實現，感覺這個方法還是很low，以后還要繼續完善。本來看到網上有用beanUtils包，利用map將查詢的一列存起來，直接轉化成該對象的，但是就是想試試新學到的反射。而且最后的垃圾回收器并不能如同C++的析構函數一樣，所以關閉數據庫鏈接的地方也需要改善。
public class Consql {
private static Consql consql=null;//單例設計模式
private Connection conn=null;//數據庫鏈接
private final String url;//數據庫url
private final String username;//數據庫用戶名
private final String password;//數據庫密碼
//驅動類的加載
static{//以靜態代碼塊的形式加載驅動類，靜態代碼塊只在類加載的時候執行一次
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
//構造函數
private Consql(String url,String username,String password) throws SQLException{
this.url = url;
this.username = username;
this.password = password;
open();//創建連接
}
private Connection open() throws SQLException
{
try {//驅動器獲取數據庫鏈接
conn=DriverManager.getConnection(url, username, password);
} catch (SQLException e) {
// TODO Auto-generated catch block
//e.printStackTrace();
throw e;
}
return conn;
}
/**
* 帶限制條件查找
* @param sql 帶占位符？的sql語句
* @param t 返回相關類型對象的類（T.class）
* @param params 替換占位符的數據，為動態數組
* @return ArrayListT>
* @throws SQLException
*/
public T> ArrayListT> select(String sql,ClassT> t,Object...params) throws SQLException
{//獲取T類所有public方法
Method[] declaredMethods = t.getDeclaredMethods();
//創建一個盛放該類型對象集合
ArrayListT> arrayList=new ArrayList>();
try (PreparedStatement pStatement=conn.prepareStatement(sql);)
{
for(int i=0;iparams.length;i++)
{
pStatement.setObject(i+1, params[i]);
}
try(ResultSet rSet=pStatement.executeQuery();)
{
ResultSetMetaData rData=rSet.getMetaData();
//獲取查詢到結果表的列數
int columnCount = rData.getColumnCount();
while (rSet.next()) {
T a=t.newInstance();//創建泛型類實例
for(int i=0;icolumnCount;i++)
{//獲得方數組里的set方法，這里造成了局限性，只能數據庫表列名與對象名一致，且只能是set方法
String aString="set"+rData.getColumnName(i+1);
for (Method method : declaredMethods) {
if(method.getParameterCount()==1method.getReturnType().toString().equals("void")method.getName().equalsIgnoreCase(aString))
{//這里存在問題，前兩個判斷條件基本沒用，主要是最初不想用上面拼串的方式來判斷是不是調用該參數的方法
method.setAccessible(true);
//利用反射調用該方法
method.invoke(a, rSet.getObject(i+1));
break;
}
}
}
arrayList.add(a);
}
} catch (InstantiationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalAccessException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalArgumentException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InvocationTargetException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
throw e;
}
return arrayList;
}
/**
* 數據插入
* @param sql 帶占位符？的sql語句
* @param params 替換占位符的數據，動態數組
* @throws SQLException
*/
public void insert(String sql,Object...params) throws SQLException
{
try(PreparedStatement pStatement=conn.prepareStatement(sql);) {
for(int i=0;iparams.length;i++)
{
pStatement.setObject(i+1, params[i]);
}
pStatement.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
throw e;
}
}
/**
* 數據更新
* @param sql 帶占位符？的sql語句
* @param params 替換占位符的數據，動態數組
* @throws SQLException
*/
public void update(String sql,Object...params) throws SQLException
{
try(PreparedStatement pStatement=conn.prepareStatement(sql);) {
for(int i=0;iparams.length;i++)
{
pStatement.setObject(i+1, params[i]);
}
pStatement.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
throw e;
}
}
/**
* 帶限制條件刪除
* @param sql 帶占位符？的sql語句
* @param params 替換占位符的數據，動態數組
* @throws SQLException
*/
public void delete(String sql,Object...params) throws SQLException
{
try(PreparedStatement pStatement=conn.prepareStatement(sql);) {
for(int i=0;iparams.length;i++)
{
pStatement.setObject(i+1, params[i]);
}
pStatement.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
throw e;
}
}
/**
* 刪除全部，不帶有限制
* @param sql
* @throws SQLException
*/
public void deleteall(String sql) throws SQLException
{
try(PreparedStatement pStatement=conn.prepareStatement(sql);) {
pStatement.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
throw e;
}
}
/**
* 無限制條件查找
* @param sql
* @param t 泛型類T.class
* @return ArrayListT>
* @throws SQLException
*/
public T> ArrayListT> select(String sql,ClassT> t) throws SQLException
{
Method[] declaredMethods = t.getDeclaredMethods();
ArrayListT> arrayList=new ArrayList>();
try (PreparedStatement pStatement=conn.prepareStatement(sql);)
{
try(ResultSet rSet=pStatement.executeQuery();)
{
ResultSetMetaData rData=rSet.getMetaData();
int columnCount = rData.getColumnCount();
while (rSet.next()) {
T a=t.newInstance();
for(int i=0;icolumnCount;i++)
{
String aString="set"+rData.getColumnName(i+1);
for (Method method : declaredMethods) {
if(method.getName().equalsIgnoreCase(aString))
{
method.setAccessible(true);
method.invoke(a, rSet.getObject(i+1));
break;
}
}
}
arrayList.add(a);
}
} catch (InstantiationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalAccessException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IllegalArgumentException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InvocationTargetException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
throw e;
}
return arrayList;
}
/**
* 返回表中數據行數
* @param tableName 數據庫表名
* @return 行數
* @throws SQLException
*/
public int count(String tableName) throws SQLException
{
String sql="select count(*) from "+tableName;
try(PreparedStatement pStatement=conn.prepareStatement(sql);
ResultSet rsSet=pStatement.executeQuery(); )
{
if(rsSet.next())
{
return rsSet.getInt(1);
}
} catch (SQLException e) {
// TODO Auto-generated catch block
throw e;
}
return 0;
}
/**
* 判斷數據是否存在
* @param sql 帶占位符？的sql語句
* @param params 替換占位符的數據，動態數組
* @return boolean
* @throws SQLException
*/
public boolean isExist(String sql,Object...params) throws SQLException
{
try(PreparedStatement pStatement=conn.prepareStatement(sql);)
{
for(int i=0;iparams.length;i++)
{
pStatement.setObject(i+1, params[i]);
}
try(ResultSet rsSet=pStatement.executeQuery();) {
if(rsSet.next())
{
return true;
}
} finally {
}
} catch (SQLException e) {
// TODO Auto-generated catch block
throw e;
}
return false;
}
/**
* 創建實例
* @param url 數據庫url
* @param username 用戶名
* @param password 密碼
* @return consql對象
* @throws SQLException
*/
public static Consql getnewInstance(String url,String username,String password) throws SQLException
{
if(consql==null)
consql=new Consql(url, username, password);
return consql;
}
//垃圾回收，貌似并不能達到析構函數的效果
protected void finalize() throws Throwable
{
if(conn!=null)
{
conn.close();
}
super.finalize();
}
}
