關於java后台數據庫的連接（增刪改查）的方法集合

Connection conn=null;
PreparedStatement pst=null;
ResultSet rs=null;

//連接數據庫
public Connection getConnection() {
try {
Class.forName("com.mysql.jdbc.Driver");

conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/monkeye?useUnicode=true&characterEncoding=UTF-8", "root", "123456");

//?后面可以加上編碼格式，設置setUnicode=true&characterEncoding=UTF-8

}catch(Exception e){
e.printStackTrace();
}
return conn;
}

//關閉數據庫的連接
public void getClose(ResultSet rs,PreparedStatement pst,Connection conn) {
try {
if(rs!=null)rs.close();
if(pst!=null)pst.close();
if(conn!=null)conn.close();
}catch(Exception e) {
e.printStackTrace();
}
}

//數據庫的增刪改方法集合
public boolean getUpdate(String sql,List<Object> list) {
try {
pst=getConnection().prepareStatement(sql);
if(list.size()>0) {
for(int i=0;i<list.size();i++) {
pst.setObject(i+1, list.get(i));//pst從下標1開始，list從下標0開始
}
}
int num=pst.executeUpdate();
if(num>0) {
return true;
}
} catch (SQLException e) {
e.printStackTrace();
}
return false;
}

//數據庫的查詢方式集合
public <T>List<T> getQuery(String sql,List<Object> list,Class clazz){
List<T> li=new ArrayList<T>();
try {
pst=getConnection().prepareStatement(sql);
if(list.size()>0) {
for(int i=0;i<list.size();i++) {
pst.setObject(i+1, list.get(i));
}
}
rs=pst.executeQuery();
ResultSetMetaData rsm=rs.getMetaData();
int column=rsm.getColumnCount();
while(rs.next()) {
Object obj=clazz.newInstance();
for(int i=1;i<=column;i++) {
String name=rsm.getColumnName(i);
Object o=rs.getObject(i);
Field f=clazz.getDeclaredField(name);   //通過名字映射獲取屬性
f.setAccessible(true);
f.set(obj, o);  //將屬性o賦給obj對象
}
li.add((T)obj);
}
} catch (Exception e) {
e.printStackTrace();
}
return li;
}