package com.tntxia.db.dao;
import java.lang.annotation.Annotation;
import java.lang.reflect.Field;
import java.sql.Connection;
import java.util.ArrayList;
import java.util.Map;
import com.tntxia.db.util.DBUtil;
public class BaseDao {
public String dbSource;
public String getDbSource() {
return dbSource;
}
public void setDbSource(String dbSource) {
this.dbSource = dbSource;
}
/**
* 获取实体的ID值
*
* @param entity
* @return
*/
public String getIdField(Object entity) {
String idField = null;
try {
Field[] fields = entity.getClass()
.getDeclaredFields();
System.out.println(fields.length);
Annotation[] annotations;
for (Field field : fields) {
annotations = field.getDeclaredAnnotations();
for (Annotation a : annotations) {
if (a.annotationType().getSimpleName().equals("Id")) {
idField = field.getName();
}
}
}
} catch (Exception ex) {
}
return idField;
}
/**
* 获取实体的ID值
*
* @param entity
* @return
*/
public String getIncrement(Object entity) {
String idField = null;
try {
Field[] fields = entity.getClass()
.getDeclaredFields();
System.out.println(fields.length);
Annotation[] annotations;
for (Field field : fields) {
annotations = field.getDeclaredAnnotations();
for (Annotation a : annotations) {
if (a.annotationType().getSimpleName().equals("Increment")) {
idField = field.getName();
}
}
}
} catch (Exception ex) {
}
return idField;
}
// 查看实体有多少个
public int getCount(Object entity) {
Field[] fields = entity.getClass().getDeclaredFields();
String sqlWhere = "";
ArrayList<String> cols = new ArrayList<String>();
cols.add("c");
String sql = "";
String className = entity.getClass().getSimpleName();
Class cl = entity.getClass();
boolean firstFlag = true;
for (int i = 0; i < fields.length; i++) {
String fieldName = fields[i].getName();
String methodName = "get" + fieldName.substring(0, 1).toUpperCase()
+ fieldName.substring(1, fieldName.length());
try {
if (cl.getMethod(methodName).invoke(entity) != null) {
if (firstFlag) {
sqlWhere += " where " + fieldName + "='"
+ cl.getMethod(methodName).invoke(entity) + "'";
firstFlag = false;
} else {
sqlWhere += " and " + fieldName + "='"
+ cl.getMethod(methodName).invoke(entity) + "'";
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
sql += "select count(*) as c from " + className + sqlWhere;
Map<String, String> result = DBUtil.getSingleResult(cols, sql);
// 判断
if (result.get("c") != null)
return Integer.valueOf(result.get("c"));
else
return 0;
}
/**
* 对象查询，输入对应表名的对象，分页大小，当前页数和排序类型
*
* @param entity
* @param pageNo
* @param pageSize
* @param orderType
* @return
* @throws Exception
*/
public Map<String, ArrayList<String>> query(Object entity, int pageNo,
int pageSize, String orderType) {
Field[] fields = entity.getClass().getDeclaredFields();
String sqlSelect = "";
String sqlWhere = "";
String sql = "";
Class cl = entity.getClass();
boolean firstFlag = true;
ArrayList<String> cols = new ArrayList<String>();
String id = this.getIdField(entity);
String className = entity.getClass().getSimpleName();
for (int i = 0; i < fields.length; i++) {
String fieldName = fields[i].getName();
if (i != fields.length - 1) {
sqlSelect += fieldName + ",";
} else {
sqlSelect += fieldName;
}
cols.add(fieldName);
String methodName = "get" + fieldName.substring(0, 1).toUpperCase()
+ fieldName.substring(1, fieldName.length());
try {
if (cl.getMethod(methodName).invoke(entity) != null) {
if (firstFlag) {
sqlWhere += " where " + fieldName + "='"
+ cl.getMethod(methodName).invoke(entity) + "'";
firstFlag = false;
} else {
sqlWhere += " and " + fieldName + "='"
+ cl.getMethod(methodName).invoke(entity) + "'";
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
if (pageNo == 1) {
sqlWhere += " order by " + id + " " + orderType;
sql = "select top " + pageSize + " " + sqlSelect + " from "
+ className + sqlWhere;
} else {
String sqlGetBottom = "";
String sqlTopAll = "";
sqlTopAll = "select top " + (pageNo * pageSize) + " " + sqlSelect
+ " from " + className + sqlWhere + " order by " + id + " "
+ orderType;
if (orderType.equalsIgnoreCase("desc")) {
sqlGetBottom = "select Min(" + id + ") from (select top "
+ ((pageNo - 1) * pageSize) + " " + id + " from "
+ className + " " + sqlWhere + " order by " + id + " "
+ orderType + ") as T1";
sql = "select * from (" + sqlTopAll + ") as T where " + id
+ "<(" + sqlGetBottom + ") order by " + id + " "
+ orderType;
} else {
sqlGetBottom = "select Max(" + id + ") from (select top "
+ ((pageNo - 1) * pageSize) + " " + id + " from "
+ className + " " + sqlWhere + " order by " + id + " "
+ orderType + ") as T1";
sql = "select * from (" + sqlTopAll + ") as T where " + id
+ ">(" + sqlGetBottom + ") order by " + id + " "
+ orderType;
}
System.out.println("sqlGetBottom:" + sqlGetBottom);
}
System.out.println("the final sql :" + sql);
Map<String, ArrayList<String>> result = DBUtil
.getArrayResult(cols, sql);
return result;
}
/**
* 对象查询，不分页
*
* @param entity
* @param pageNo
* @param pageSize
* @param orderType
* @return
* @throws Exception
*/
public Map<String, ArrayList<String>> query(Object entity) {
Field[] fields = entity.getClass().getDeclaredFields();
String sqlSelect = "";
String sqlWhere = "";
String sql = "";
Class cl = entity.getClass();
boolean firstFlag = true;
ArrayList<String> cols = new ArrayList<String>();
String id = this.getIdField(entity);
String className = entity.getClass().getSimpleName();
for (int i = 0; i < fields.length; i++) {
String fieldName = fields[i].getName();
if (i != fields.length - 1) {
sqlSelect += fieldName + ",";
} else {
sqlSelect += fieldName;
}
cols.add(fieldName);
String methodName = "get" + fieldName.substring(0, 1).toUpperCase()
+ fieldName.substring(1, fieldName.length());
try {
if (cl.getMethod(methodName).invoke(entity) != null) {
if (firstFlag) {
sqlWhere += " where " + fieldName + "='"
+ cl.getMethod(methodName).invoke(entity) + "'";
firstFlag = false;
} else {
sqlWhere += " and " + fieldName + "='"
+ cl.getMethod(methodName).invoke(entity) + "'";
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
sql = "select " + sqlSelect + " from " + className + sqlWhere;
System.out.println("the final sql :" + sql);
Map<String, ArrayList<String>> result = DBUtil
.getArrayResult(cols, sql);
return result;
}
public void update(Object entity) {
Field[] fields = entity.getClass().getDeclaredFields();
Class cl = entity.getClass();
boolean firstFlag = true;
ArrayList<String> params = new ArrayList<String>();
String id = this.getIdField(entity);
String className = entity.getClass().getSimpleName();
String sqlUpdate = "";
String idValue = null;
for (int i = 0; i < fields.length; i++) {
String fieldName = fields[i].getName();
String methodName = "get" + fieldName.substring(0, 1).toUpperCase()
+ fieldName.substring(1, fieldName.length());
if (!fieldName.equals(id)) {
if (i != fields.length - 1) {
sqlUpdate += fieldName + "=? , ";
} else {
sqlUpdate += field
know.rar （56个子文件） 
know 
.project 1KB .mymetadata 285B src com tntxia db dao CategoryDao.java 382B BaseDao.java 14KB util DBUtil.java 9KB entity OperateLog.java 1KB KnowItem.java 691B Increment.java 228B Id.java 214B Category.java 509B ApplyingUser.java 818B servlet handle.java 1003B CommonResult.java 456B bean ApplyingBeans.java 238B ApplyingBean.java 344B know action DoAction.java 2KB know.properties 41B WebRoot WEB-INF classes com tntxia db dao CategoryDao.class 1KB BaseDao.class 11KB util DBUtil.class 11KB entity Increment.class 375B Category.class 979B OperateLog.class 2KB Id.class 354B KnowItem.class 1KB ApplyingUser.class 1KB servlet handle.class 1KB CommonResult.class 794B bean ApplyingBean.class 728B ApplyingBeans.class 546B know action DoAction.class 2KB know.properties 41B lib web.xml 730B showKnowItem.jsp 3KB mainItem.jsp 983B addCategory.jsp 360B modifyKnowItem.jsp 1KB index.jsp 392B images 
20100605162835-1296046091.jpg 24KB
wenwen_logo.gif 2KB com-20100606114304-556324974.jpg 5KB u113.gif 810B asklogo88x31.gif 2KB js an.js 5KB wa_15.js 6KB w_base_201006011028.js 52KB s_base.js 3KB question_201006011028.js 42KB META-INF MANIFEST.MF 39B mainCategory.jsp 882B css question_201006021050.css 51KB s_base_1.css 10KB w_base_201006011028.css 10KB addKnowItem.jsp 412B .myeclipse .settings org.eclipse.jdt.core.prefs 330B .classpath 434B资源评论
weixin_38669628
- 粉丝: 387
- 资源: 6万+
最新资源
- 工具变量-中国省级新质生产力数据(2010-2023年).xlsx
- 工具变量-中国省级新质生产力数据(2010-2023年).dta
- linux批量配置防火墙脚本firewall.sh
- jdk8 开发者中文手册
- CANoe中如何定义 <结构体数组> 类型的系统变量
- 一个用 Python 实现的猜数字游戏源码，玩家需要在一定范围内猜出程序预设的数字，程序会根据玩家的猜测给出提示，直到玩家猜对为止
- ESP8266+OLED实时显示天气和时间
- 基于CAPL内置函数，提取DBC报文信号属性信息
- 特别推荐的是 mysqlclient-1.4.6-cp37-cp37m-win-amd64.whl 文件等，专为 Windows 64 位系统下的 Python 3.6 3.7 3.8 环境设计
- flink siddhi 资源jar包，flink与siddhi集成，实现对复杂事件的处理 在flink中直接引入即可
- 多领域视角下的Cursor概念解析：数据库、GUI和编程中的应用及作用
- 一个使用 Python 进行数据分析的源码，它读取一个包含学生成绩的 CSV 文件，计算每个学生的平均成绩，并找出平均成绩最高的学生
- es 8.17.0 apache-skywalking-apm-10.1.0，同时配合elasticsearch-8.17.0-windows-x86-64来作为存储 es持久化数据使用
- MySQL 安装与配置详细步骤介绍及用途
- 计算机视觉中YOLOv11的目标检测技术创新及广泛应用
- apache-skywalking-apm-10.1.0 elasticsearch-8.17.0-windows-x86-64andapache-skywalking-apm-10.1.0
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
