人妻少妇进入猛烈时中文字幕_ 操作數據庫的基類(lèi)

Java代碼

package com.huicui.util;
import java.io.Serializable;
import java.text.DateFormat;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import org.apache.log4j.Logger;
import org.hibernate.Criteria;
import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.criterion.Criterion;
import org.hibernate.criterion.Expression;
import org.hibernate.criterion.Order;
import com.dudujava.model.HibernateSessionFactory;
/**
*
*
* @author dudujava
*
*/
public class DBUtil {
static Logger logger = Logger.getLogger(DBUtil.class.getName());
@SuppressWarnings("unchecked")
public static void main(String[] args) throws Exception {
}
public static Object findByID(String objfullname, int id) {
try {
return HibernateSessionFactory.getSession().get(objfullname.trim(),
id);
} catch (Exception e) {
logger.error(e);
e.printStackTrace();
return null;// TODO: handle exception
}
}
public static Object findByID(String objfullname, String id) {
Integer itemp = null;
try {
itemp = Integer.parseInt(id);
} catch (Exception e) {
logger.error(e); // TODO: handle exception
}
return findByID(objfullname, itemp);
}
public static void modify(String sfullname, int id, Map map) {
if (map.isEmpty())
return;
try {
Object obj = findByID(sfullname, id);
save(obj, map);
} catch (Exception e) {
// TODO Auto-generated catch block
logger.error(e);
e.printStackTrace();
}
}
public static void modify(String sfullname, String sid, Map map) {
modify(sfullname,Integer.parseInt(sid), map);
}
/**
* @param obj
*/
public static int save(Object obj) {
Transaction tx = null;
Session session = null;
try {
session = HibernateSessionFactory.getSession();
tx = session.beginTransaction();
Serializable sObj = session.save(obj);
tx.commit();
return (Integer.parseInt(sObj.toString()));
} catch (HibernateException e) {
tx.rollback();
e.printStackTrace();
logger.error(e);
return -1;
} finally {
try {
session.close();
} catch (Exception e) {
}
}
}
/**
* @param obj
*/
public static void delete(Object obj) {
Transaction tx = null;
Session session = null;
try {
session = HibernateSessionFactory.getSession();
tx = session.beginTransaction();
session.delete(obj);
tx.commit();
} catch (HibernateException e) {
tx.rollback();
logger.error(e);
e.printStackTrace();
} finally {
try {
session.close();
} catch (Exception e) {
}
}
}
/**
* @param listobj POJO List
*/
@SuppressWarnings("unchecked")
public static void delete(List listobj) {
Transaction tx = null;
Session session = null;
try {
session = HibernateSessionFactory.getSession();
tx = session.beginTransaction();
for (int i = 0; i < listobj.size(); i++) {
session.delete(listobj.get(i));
}
tx.commit();
} catch (HibernateException e) {
tx.rollback();
e.printStackTrace();
} finally {
try {
session.close();
} catch (Exception e) {
}
}
}
/**
*
* @param sql HQL
* eg:delete from User where Country.id=1;
*/
public static int modify(String sql) {
Transaction tx = null;
Session session = null;
try {
session = HibernateSessionFactory.getSession();
tx = session.beginTransaction();
Query q = session.createQuery(sql);
int itmep = q.executeUpdate();
tx.commit();
return itmep;
} catch (HibernateException e) {
tx.rollback();
e.printStackTrace();
return -1;
} finally {
try {
session.close();
} catch (Exception e) {
}
}
}
public static int modifyBYHql(String sql) {
Transaction tx = null;
Session session = null;
try {
session = HibernateSessionFactory.getSession();
tx = session.beginTransaction();
Query q = session.createQuery(sql);
int itmep = q.executeUpdate();
tx.commit();
return itmep;
} catch (HibernateException e) {
tx.rollback();
e.printStackTrace();
return -1;
} finally {
try {
session.close();
} catch (Exception e) {
}
}
}
public static int modifyBYsql(String sql) {
Transaction tx = null;
Session session = null;
try {
session = HibernateSessionFactory.getSession();
tx = session.beginTransaction();
Query q = session.createSQLQuery(sql);
int itmep = q.executeUpdate();
tx.commit();
return itmep;
} catch (HibernateException e) {
tx.rollback();
e.printStackTrace();
return -1;
} finally {
try {
session.close();
} catch (Exception e) {
}
}
}
/**
* @param classname
* @param sObjID
* @throws Exception
*/
public static void delete(String classname, String sObjID)
throws Exception {
Transaction tx = null;
Session session = null;
try {
session = HibernateSessionFactory.getSession();
tx = session.beginTransaction();
Object obj = findByID(classname, sObjID);
if (obj != null)
session.delete(obj);
tx.commit();
} catch (HibernateException e) {
tx.rollback();
logger.error(e);
e.printStackTrace();
} finally {
try {
session.close();
} catch (Exception e) {
}
}
}
public static void save(List list) {
Transaction tx = null;
Session session = null;
try {
session = HibernateSessionFactory.getSession();
tx = session.beginTransaction();
for (int i = 0; i < list.size(); i++) {
session.save(list.get(i));
}
tx.commit();
} catch (HibernateException e) {
tx.rollback();
e.printStackTrace();
logger.error(e);
} finally {
try {
session.close();
} catch (Exception e) {
}
}
logger.debug("save successfull save object number:"+list.size());
}
@SuppressWarnings("unchecked")
public static int save(String sname, Map map) {
Object objtemp = null;
try {
objtemp =Class.forName(sname.trim()).newInstance();
} catch (Exception e1) {
// TODO Auto-generated catch block
logger.error(e1);
e1.printStackTrace();
}
return DBUtil.save(objtemp,map);
}
@SuppressWarnings("unchecked")
public static int save(String sname,String sid, Map map) {
Object objtemp = null;
try {
objtemp =findByID(sname,sid);
} catch (Exception e1) {
// TODO Auto-generated catch block
logger.error(e1);
e1.printStackTrace();
}
return DBUtil.save(objtemp,map);
}
@SuppressWarnings("unchecked")
public static int save(Object objtemp, Map map) {
String skey = "";
Iterator it = map.keySet().iterator();
while (it.hasNext()) {
skey = it.next().toString().trim();
if (skey.length() == 0) {
logger.error("key not allow NULL ,MAP:" + map);
continue;
}
Object[] args = new Object[1];
args[0] = map.get(skey);
try {
ReflectUtil.invokeMethod(objtemp, "set"
+ skey.substring(0, 1).toUpperCase()
+ skey.substring(1), args);
} catch (Exception e) {
e.printStackTrace();
logger.error(e);
return -1;
}
}
return DBUtil.save(objtemp);
}
public static List searchByHql(String sql) {
return HibernateSessionFactory.getSession().createQuery(sql).list();
}
public static List searchBySql(String sql) {
try {
return HibernateSessionFactory.getSession().createSQLQuery(sql)
.list();
} catch (Exception e) {
e.printStackTrace();
System.out.println("your input sql is incorrect!");
// TODO: handle exception
}
return null;
}
@SuppressWarnings("unchecked")
public static List search(String classname, Map map, int ibegin, int inum)
{
List list = new ArrayList();
Session session = null;
Transaction tran = null;
try {
session = HibernateSessionFactory.getSession();
tran = session.beginTransaction();
Criteria temp = session.createCriteria(Class.forName(classname));
String skey = "";
Iterator it = map.keySet().iterator();
while (it.hasNext()) {
Object obj = it.next();
if (obj instanceof List) {
List listTemp = (List) obj;
for (int i = 0; i < listTemp.size(); i++) {
temp = temp.add((Criterion) (listTemp.get(i)));
}
continue;
}
if (obj instanceof Order) {
temp = temp.addOrder((Order) obj);
continue;
}
skey = obj.toString();
temp = temp.add(Expression.eq(skey, map.get(skey)));
}
temp.setFirstResult(ibegin);
temp.setMaxResults(inum);
list = temp.list();
} catch (Exception e) {
// e.printStackTrace();
} finally {
session.close();
}
return list;
}
/**
* @param classname
* @param map
* @return
* @throws Exception
*/
@SuppressWarnings("unchecked")
public static List search(String classname, Map map) {
List list = new ArrayList();
Session session = null;
Transaction tran = null;
try {
session = HibernateSessionFactory.getSession();
Criteria temp = session.createCriteria(Class.forName(classname));
if (map.isEmpty())
return temp.list();
String skey = "";
Iterator it = map.keySet().iterator();
while (it.hasNext()) {
Object obj = it.next();
if (obj instanceof List) {
List listTemp = (List) obj;
for (int i = 0; i < listTemp.size(); i++) {
temp = temp.add((Criterion) (listTemp.get(i)));
}
continue;
}
if (obj instanceof Order) {
temp = temp.addOrder((Order) obj);
continue;
}
skey = obj.toString();
temp = temp.add(Expression.eq(skey, map.get(skey)));
}
list = temp.list();
} catch (Exception e) {
logger.info(e);
e.printStackTrace();
} finally {
session.close();
}
return list;
}
/**
* @param classname POJO full name
* @param map put restrictions keys values
* @param sprefix input data prefix
* @return POJO list
* @throws Exception
*/
@SuppressWarnings("unchecked")
public static List search(String classname, Map map, String sprefix)
{
List list = new ArrayList();
Session session = null;
Transaction tran = null;
List pc = null;
try {
session = HibernateSessionFactory.getSession();
tran = session.beginTransaction();
Criteria temp = session.createCriteria(Class.forName(classname));
if (map.isEmpty())
return temp.list();
temp.setMaxResults(50);
String skey = "";
map = doFilter(map, sprefix);
Iterator it = map.keySet().iterator();
while (it.hasNext()) {
Object obj = it.next();
if (obj instanceof List) {
List listTemp = (List) obj;
for (int i = 0; i < listTemp.size(); i++) {
temp = temp.add((Criterion) (listTemp.get(i)));
}
continue;
}
if (obj instanceof Order) {
temp = temp.addOrder((Order) obj);
continue;
}
skey = obj.toString();
temp = temp.add(Expression.eq(skey, map.get(skey)));
}
list = temp.list();
} catch (Exception e) {
logger.info(e);
// e.printStackTrace();
} finally {
session.close();
}
return list;
}
@SuppressWarnings("unchecked")
public static Map doFilter(Map map) {
return doFilter(map, "para");
}
@SuppressWarnings("unchecked")
public static Map doFilter(Map map, String sprefix) {
if (sprefix == null || sprefix.trim().length() == 0)
sprefix = "para";
return doFilter(map, sprefix, false);
}
}

本站僅提供存儲服務(wù)，所有內容均由用戶(hù)發(fā)布，如發(fā)現有害或侵權內容，請點(diǎn)擊舉報。

欧美性猛交XXXX免费看蜜桃,成人网18免费韩国,亚洲国产成人精品区综合,欧美日韩一区二区三区高清不卡,亚洲综合一区二区精品久久