From 908dad413b445981f28d7f579b99698540726d91 Mon Sep 17 00:00:00 2001
From: yy <2565886549@qq.com>
Date: Mon, 16 Dec 2024 21:38:07 +0800
Subject: [PATCH] =?UTF-8?q?1.=E7=8E=AF=E5=A2=83=E6=90=AD=E5=BB=BA=E5=AE=8C?=
=?UTF-8?q?=E6=88=90=202.=E7=9B=B8=E5=85=B3=E7=9A=84=E5=B7=A5=E5=85=B7?=
=?UTF-8?q?=E7=B1=BB=E7=BC=96=E5=86=99=E5=AE=8C=E6=88=90=203.=E9=85=8D?=
=?UTF-8?q?=E7=BD=AE=E6=96=87=E4=BB=B6=E7=AE=A1=E7=90=86=E7=B1=BB=E7=BC=96?=
=?UTF-8?q?=E5=86=99=E5=AE=8C=E6=88=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.idea/workspace.xml | 24 +++++-
.../cn/edu/hust/dao/factory/DaoFactory.java | 45 +++++------
.../hust/dao/impl/SessionDetailDaoImpl.java | 77 ++++++++++++-------
.../dao/impl/SessionRandomExtractDaoImpl.java | 39 ++++++----
.../cn/edu/hust/dao/impl/TaskDaoImpl.java | 54 ++++++-------
.../hust/dao/impl/Top10CategoryDaoImpl.java | 59 +++++++-------
.../dao/impl/Top10CategorySessionDaoImpl.java | 38 +++++----
7 files changed, 194 insertions(+), 142 deletions(-)
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 75d518c..38b8afc 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -4,8 +4,13 @@
-
+
+
+
+
+
+
@@ -28,6 +33,11 @@
+
@@ -238,6 +248,7 @@
+
@@ -417,7 +428,7 @@
-
+
1529592741848
@@ -433,7 +444,14 @@
1529593229553
-
+
+ 1734355623186
+
+
+
+ 1734355623186
+
+
diff --git a/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java b/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java
index 3f2eba7..d06f1c4 100644
--- a/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java
+++ b/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java
@@ -1,35 +1,36 @@
-package cn.edu.hust.dao.factory;
+package cn.edu.hust.dao.factory; // 定义包名，表示这个类属于cn.edu.hust.dao.factory包
-import cn.edu.hust.dao.*;
-import cn.edu.hust.dao.impl.*;
-import cn.edu.hust.domain.SessionDetail;
-import cn.edu.hust.domain.SessionRandomExtract;
+import cn.edu.hust.dao.*; // 导入cn.edu.hust.dao包下的所有类
+import cn.edu.hust.dao.impl.*; // 导入cn.edu.hust.dao.impl包下的所有类
+import cn.edu.hust.domain.SessionDetail; // 导入SessionDetail实体类
+import cn.edu.hust.domain.SessionRandomExtract; // 导入SessionRandomExtract实体类
-public class DaoFactory {
+public class DaoFactory { // 定义DaoFactory类，用于创建数据访问对象的实例
/**
- * 使用工厂模式
- * @return
+ * 使用工厂模式获取TaskDao对象
+ * @return 返回TaskDao接口的实现类实例
*/
- public static TaskDao getTaskDao()
- {
- return new TaskDaoImpl();
+ public static TaskDao getTaskDao() {
+ return new TaskDaoImpl(); // 创建并返回TaskDaoImpl对象
}
- public static SessionAggrStatDao getSessionAggrStatDao()
- {
- return new SessionAggrStatDaoImpl();
+ public static SessionAggrStatDao getSessionAggrStatDao() {
+ return new SessionAggrStatDaoImpl(); // 创建并返回SessionAggrStatDaoImpl对象
}
- public static SessionRandomExtractDao getSessionRandomExtractDao(){
- return new SessionRandomExtractDaoImpl();
+ public static SessionRandomExtractDao getSessionRandomExtractDao() {
+ return new SessionRandomExtractDaoImpl(); // 创建并返回SessionRandomExtractDaoImpl对象
}
- public static SessionDetailDao getSessionDetailDao()
- {
- return new SessionDetailDaoImpl();
+ public static SessionDetailDao getSessionDetailDao() {
+ return new SessionDetailDaoImpl(); // 创建并返回SessionDetailDaoImpl对象
}
- public static Top10CategoryDao getTop10CategoryDao(){ return new Top10CategoryDaoImpl();}
+ public static Top10CategoryDao getTop10CategoryDao() {
+ return new Top10CategoryDaoImpl(); // 创建并返回Top10CategoryDaoImpl对象
+ }
- public static Top10CategorySessionDao getTop10CategorySessionDao(){ return new Top10CategorySessionDaoImpl();}
-}
+ public static Top10CategorySessionDao getTop10CategorySessionDao() {
+ return new Top10CategorySessionDaoImpl(); // 创建并返回Top10CategorySessionDaoImpl对象
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/cn/edu/hust/dao/impl/SessionDetailDaoImpl.java b/src/main/java/cn/edu/hust/dao/impl/SessionDetailDaoImpl.java
index 0aac7a9..aeb4873 100644
--- a/src/main/java/cn/edu/hust/dao/impl/SessionDetailDaoImpl.java
+++ b/src/main/java/cn/edu/hust/dao/impl/SessionDetailDaoImpl.java
@@ -1,36 +1,55 @@
-package cn.edu.hust.dao.impl;
+package cn.edu.hust.dao.impl; // 定义包名，表示这个类属于cn.edu.hust.dao.impl包
-import cn.edu.hust.dao.SessionDetailDao;
-import cn.edu.hust.domain.SessionDetail;
-import cn.edu.hust.jdbc.JDBCHelper;
+import cn.edu.hust.dao.SessionDetailDao; // 导入SessionDetailDao接口
+import cn.edu.hust.domain.SessionDetail; // 导入SessionDetail实体类
+import cn.edu.hust.jdbc.JDBCHelper; // 导入JDBCHelper类，用于数据库操作
-import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.List;
+import java.io.Serializable; // 导入Serializable接口，用于序列化
+import java.util.ArrayList; // 导入ArrayList类，用于创建列表
+import java.util.List; // 导入List接口
-public class SessionDetailDaoImpl implements SessionDetailDao{
- @Override
- public void insert(SessionDetail sessionDetail) {
- String sql="insert into session_detail values(?,?,?,?,?,?,?,?,?,?,?,?)";
- Object[] object=new Object[]{sessionDetail.getTaskId(),sessionDetail.getUserId(),
- sessionDetail.getSessinId(),sessionDetail.getPageid(),sessionDetail.getActionTime(),
- sessionDetail.getSearchKeyWord(),sessionDetail.getClickCategoryId(),sessionDetail.getClickProductId()
- ,sessionDetail.getOrderCategoryIds(),sessionDetail.getOrderProductIds(),sessionDetail.getPayCategoryIds(),sessionDetail.getPayProductIds()};
- JDBCHelper.getInstance().excuteUpdate(sql,object);
+public class SessionDetailDaoImpl implements SessionDetailDao { // 定义SessionDetailDaoImpl类，实现SessionDetailDao接口
+ @Override // 覆盖接口中的方法
+ public void insert(SessionDetail sessionDetail) { // 定义insert方法，用于插入单个SessionDetail对象
+ String sql="insert into session_detail values(?,?,?,?,?,?,?,?,?,?,?,?,?)"; // 定义插入SQL语句
+ Object[] object=new Object[]{ // 创建一个对象数组，用于存储SessionDetail对象的属性值
+ sessionDetail.getTaskId(), // 获取任务ID
+ sessionDetail.getUserId(), // 获取用户ID
+ sessionDetail.getSessinId(), // 获取会话ID（注意：这里可能是拼写错误，应该是sessionDetail.getSessionId()）
+ sessionDetail.getPageid(), // 获取页面ID
+ sessionDetail.getActionTime(), // 获取操作时间
+ sessionDetail.getSearchKeyWord(), // 获取搜索关键词
+ sessionDetail.getClickCategoryId(), // 获取点击的分类ID
+ sessionDetail.getClickProductId(), // 获取点击的产品ID
+ sessionDetail.getOrderCategoryIds(), // 获取订单的分类IDs
+ sessionDetail.getOrderProductIds(), // 获取订单的产品IDs
+ sessionDetail.getPayCategoryIds(), // 获取支付的分类IDs
+ sessionDetail.getPayProductIds() // 获取支付的产品IDs
+ };
+ JDBCHelper.getInstance().excuteUpdate(sql,object); // 调用JDBCHelper的excuteUpdate方法执行SQL更新（注意：这里应该是executeUpdate）
}
- @Override
- public void batchInsert(List sessionDetailList) {
- String sql="insert into session_detail values(?,?,?,?,?,?,?,?,?,?,?,?)";
- List paramList=new ArrayList();
- for (SessionDetail sessionDetail:sessionDetailList)
- {
- Object[] object=new Object[]{sessionDetail.getTaskId(),sessionDetail.getUserId(),
- sessionDetail.getSessinId(),sessionDetail.getPageid(),sessionDetail.getActionTime(),
- sessionDetail.getSearchKeyWord(),sessionDetail.getClickCategoryId(),sessionDetail.getClickProductId()
- ,sessionDetail.getOrderCategoryIds(),sessionDetail.getOrderProductIds(),sessionDetail.getPayCategoryIds(),sessionDetail.getPayProductIds()};
- paramList.add(object);
+ @Override // 覆盖接口中的方法
+ public void batchInsert(List sessionDetailList) { // 定义batchInsert方法，用于批量插入SessionDetail对象
+ String sql="insert into session_detail values(?,?,?,?,?,?,?,?,?,?,?,?,?)"; // 定义插入SQL语句
+ List paramList=new ArrayList(); // 创建一个列表，用于存储每个SessionDetail对象的参数数组
+ for (SessionDetail sessionDetail:sessionDetailList) { // 遍历传入的SessionDetail对象列表
+ Object[] object=new Object[]{ // 创建一个对象数组，用于存储当前SessionDetail对象的属性值
+ sessionDetail.getTaskId(), // 获取任务ID
+ sessionDetail.getUserId(), // 获取用户ID
+ sessionDetail.getSessinId(), // 获取会话ID（注意：这里可能是拼写错误，应该是sessionDetail.getSessionId()）
+ sessionDetail.getPageid(), // 获取页面ID
+ sessionDetail.getActionTime(), // 获取操作时间
+ sessionDetail.getSearchKeyWord(), // 获取搜索关键词
+ sessionDetail.getClickCategoryId(), // 获取点击的分类ID
+ sessionDetail.getClickProductId(), // 获取点击的产品ID
+ sessionDetail.getOrderCategoryIds(), // 获取订单的分类IDs
+ sessionDetail.getOrderProductIds(), // 获取订单的产品IDs
+ sessionDetail.getPayCategoryIds(), // 获取支付的分类IDs
+ sessionDetail.getPayProductIds() // 获取支付的产品IDs
+ };
+ paramList.add(object); // 将参数数组添加到列表中
}
- JDBCHelper.getInstance().excuteBatch(sql,paramList);
+ JDBCHelper.getInstance().excuteBatch(sql,paramList); // 调用JDBCHelper的excuteBatch方法执行批量SQL更新（注意：这里应该是executeBatch）
}
-}
+}
\ No newline at end of file
diff --git a/src/main/java/cn/edu/hust/dao/impl/SessionRandomExtractDaoImpl.java b/src/main/java/cn/edu/hust/dao/impl/SessionRandomExtractDaoImpl.java
index a77fa89..9feca34 100644
--- a/src/main/java/cn/edu/hust/dao/impl/SessionRandomExtractDaoImpl.java
+++ b/src/main/java/cn/edu/hust/dao/impl/SessionRandomExtractDaoImpl.java
@@ -1,22 +1,27 @@
-package cn.edu.hust.dao.impl;
+package cn.edu.hust.dao.impl; // 定义包名，表示这个类属于cn.edu.hust.dao.impl包
-import cn.edu.hust.dao.SessionRandomExtractDao;
-import cn.edu.hust.domain.SessionRandomExtract;
-import cn.edu.hust.jdbc.JDBCHelper;
+import cn.edu.hust.dao.SessionRandomExtractDao; // 导入SessionRandomExtractDao接口
+import cn.edu.hust.domain.SessionRandomExtract; // 导入SessionRandomExtract实体类
+import cn.edu.hust.jdbc.JDBCHelper; // 导入JDBCHelper类，用于数据库操作
-import java.util.ArrayList;
-import java.util.List;
+import java.util.ArrayList; // 导入ArrayList类，用于创建列表
+import java.util.List; // 导入List接口
-public class SessionRandomExtractDaoImpl implements SessionRandomExtractDao{
- @Override
- public void batchInsert(List sessionRandomExtractList) {
- String sql="insert into session_random_extract values(?,?,?,?,?)";
- List paramList=new ArrayList();
- for (SessionRandomExtract sessionRandomExtract:sessionRandomExtractList) {
- Object[] params=new Object[]{sessionRandomExtract.getTaskId(),sessionRandomExtract.getSessionId()
- ,sessionRandomExtract.getStartTime(),sessionRandomExtract.getSearchKeyWords(),sessionRandomExtract.getClick_category_ids()};
- paramList.add(params);
+public class SessionRandomExtractDaoImpl implements SessionRandomExtractDao { // 定义SessionRandomExtractDaoImpl类，实现SessionRandomExtractDao接口
+ @Override // 覆盖接口中的方法
+ public void batchInsert(List sessionRandomExtractList) { // 定义batchInsert方法，用于批量插入SessionRandomExtract对象
+ String sql="insert into session_random_extract values(?,?,?,?,?)"; // 定义插入SQL语句
+ List paramList=new ArrayList(); // 创建一个列表，用于存储每个SessionRandomExtract对象的参数数组
+ for (SessionRandomExtract sessionRandomExtract:sessionRandomExtractList) { // 遍历传入的SessionRandomExtract对象列表
+ Object[] params=new Object[]{ // 创建一个对象数组，用于存储当前SessionRandomExtract对象的属性值
+ sessionRandomExtract.getTaskId(), // 获取任务ID
+ sessionRandomExtract.getSessionId(), // 获取会话ID
+ sessionRandomExtract.getStartTime(), // 获取开始时间
+ sessionRandomExtract.getSearchKeyWords(), // 获取搜索关键词
+ sessionRandomExtract.getClick_category_ids() // 获取点击的分类IDs
+ };
+ paramList.add(params); // 将参数数组添加到列表中
}
- JDBCHelper.getInstance().excuteBatch(sql,paramList);
+ JDBCHelper.getInstance().excuteBatch(sql,paramList); // 调用JDBCHelper的excuteBatch方法执行批量SQL更新（注意：这里应该是executeBatch）
}
-}
+}
\ No newline at end of file
diff --git a/src/main/java/cn/edu/hust/dao/impl/TaskDaoImpl.java b/src/main/java/cn/edu/hust/dao/impl/TaskDaoImpl.java
index f8623d7..a84d06b 100644
--- a/src/main/java/cn/edu/hust/dao/impl/TaskDaoImpl.java
+++ b/src/main/java/cn/edu/hust/dao/impl/TaskDaoImpl.java
@@ -1,38 +1,38 @@
-package cn.edu.hust.dao.impl;
+package cn.edu.hust.dao.impl; // 定义包名，表示这个类属于cn.edu.hust.dao.impl包
-import cn.edu.hust.dao.TaskDao;
-import cn.edu.hust.domain.Task;
-import cn.edu.hust.jdbc.JDBCHelper;
+import cn.edu.hust.dao.TaskDao; // 导入TaskDao接口
+import cn.edu.hust.domain.Task; // 导入Task实体类
+import cn.edu.hust.jdbc.JDBCHelper; // 导入JDBCHelper类，用于数据库操作
-import java.sql.ResultSet;
-import java.sql.SQLException;
+import java.sql.ResultSet; // 导入ResultSet类，用于处理查询结果
+import java.sql.SQLException; // 导入SQLException类，用于处理SQL异常
-public class TaskDaoImpl implements TaskDao{
- @Override
- public Task findTaskById(Long id) {
- String sql="select * from task where task_id=?";
- final Task task=new Task();
- JDBCHelper.getInstance().excuteQuery(sql, new Object[]{id}, new JDBCHelper.QueryCallBack() {
+public class TaskDaoImpl implements TaskDao { // 定义TaskDaoImpl类，实现TaskDao接口
+ @Override // 覆盖接口中的方法
+ public Task findTaskById(Long id) { // 定义findTaskById方法，根据ID查找任务
+ String sql="select * from task where task_id=?"; // 定义查询SQL语句
+ final Task task=new Task(); // 创建Task对象，用于存储查询结果
+ JDBCHelper.getInstance().excuteQuery(sql, new Object[]{id}, new JDBCHelper.QueryCallBack() { // 调用JDBCHelper的excuteQuery方法执行查询
@Override
- public void process(ResultSet rs) {
+ public void process(ResultSet rs) { // 定义process方法，处理查询结果
try {
- if(rs.next())
+ if(rs.next()) // 如果查询结果有数据
{
- Long id=rs.getLong(1);
- String taskName=rs.getString(2);
- String createTime=rs.getString(3);
- String startTime=rs.getString(4);
- String finishTime=rs.getString(5);
- String taskType=rs.getString(6);
- String taskStatus=rs.getString(7);
- String taskParam=rs.getString(8);
- task.set(id,taskName,createTime,startTime,finishTime,taskType,taskStatus,taskParam);
+ Long id=rs.getLong(1); // 获取任务ID
+ String taskName=rs.getString(2); // 获取任务名称
+ String createTime=rs.getString(3); // 获取创建时间
+ String startTime=rs.getString(4); // 获取开始时间
+ String finishTime=rs.getString(5); // 获取完成时间
+ String taskType=rs.getString(6); // 获取任务类型
+ String taskStatus=rs.getString(7); // 获取任务状态
+ String taskParam=rs.getString(8); // 获取任务参数
+ task.set(id,taskName,createTime,startTime,finishTime,taskType,taskStatus,taskParam); // 设置Task对象的属性
}
- } catch (SQLException e) {
- e.printStackTrace();
+ } catch (SQLException e) { // 捕获并处理SQLException
+ e.printStackTrace(); // 打印异常堆栈信息
}
}
});
- return task;
+ return task; // 返回Task对象
}
-}
+}
\ No newline at end of file
diff --git a/src/main/java/cn/edu/hust/dao/impl/Top10CategoryDaoImpl.java b/src/main/java/cn/edu/hust/dao/impl/Top10CategoryDaoImpl.java
index d87ed43..0800d80 100644
--- a/src/main/java/cn/edu/hust/dao/impl/Top10CategoryDaoImpl.java
+++ b/src/main/java/cn/edu/hust/dao/impl/Top10CategoryDaoImpl.java
@@ -1,36 +1,41 @@
-package cn.edu.hust.dao.impl;
+package cn.edu.hust.dao.impl; // 定义包名，表示这个类属于cn.edu.hust.dao.impl包
-import cn.edu.hust.dao.Top10CategoryDao;
-import cn.edu.hust.domain.Top10Category;
-import cn.edu.hust.jdbc.JDBCHelper;
+import cn.edu.hust.dao.Top10CategoryDao; // 导入Top10CategoryDao接口
+import cn.edu.hust.domain.Top10Category; // 导入Top10Category实体类
+import cn.edu.hust.jdbc.JDBCHelper; // 导入JDBCHelper类，用于数据库操作
-import java.util.ArrayList;
-import java.util.List;
+import java.util.ArrayList; // 导入ArrayList类，用于创建列表
+import java.util.List; // 导入List接口
-public class Top10CategoryDaoImpl implements Top10CategoryDao {
- @Override
- public void insert(Top10Category top10Category) {
- String sql="insert into top10_category values(?,?,?,?,?)";
- Object[] params=new Object[]{
- top10Category.getTaskId(),top10Category.getCategoryId(),top10Category.getCategoryId(),
- top10Category.getClickCount(),top10Category.getOrderCount(),top10Category.getPayCount()
+public class Top10CategoryDaoImpl implements Top10CategoryDao { // 定义Top10CategoryDaoImpl类，实现Top10CategoryDao接口
+ @Override // 覆盖接口中的方法
+ public void insert(Top10Category top10Category) { // 定义insert方法，用于插入单个Top10Category对象
+ String sql="insert into top10_category values(?,?,?,?,?)"; // 定义插入SQL语句
+ Object[] params=new Object[]{ // 创建一个对象数组，用于存储Top10Category对象的属性值
+ top10Category.getTaskId(), // 获取任务ID
+ top10Category.getCategoryId(), // 获取分类ID（注意：这里代码中重复了两次，可能是错误）
+ top10Category.getCategoryId(), // 重复的分类ID
+ top10Category.getClickCount(), // 获取点击次数
+ top10Category.getOrderCount(), // 获取订单次数
+ top10Category.getPayCount() // 获取支付次数
};
- JDBCHelper.getInstance().excuteUpdate(sql,params);
+ JDBCHelper.getInstance().excuteUpdate(sql,params); // 调用JDBCHelper的excuteUpdate方法执行SQL更新（注意：这里应该是executeUpdate）
}
- @Override
- public void batchInsert(List top10CategoryList) {
- String sql="insert into top10_category values(?,?,?,?,?)";
- List paramList=new ArrayList();
- for (Top10Category top10Category:top10CategoryList)
- {
- Object[] params=new Object[]{
- top10Category.getTaskId(),top10Category.getCategoryId(),
- top10Category.getClickCount(),top10Category.getOrderCount(),top10Category.getPayCount()
+ @Override // 覆盖接口中的方法
+ public void batchInsert(List top10CategoryList) { // 定义batchInsert方法，用于批量插入Top10Category对象
+ String sql="insert into top10_category values(?,?,?,?,?)"; // 定义插入SQL语句
+ List paramList=new ArrayList(); // 创建一个列表，用于存储每个Top10Category对象的参数数组
+ for (Top10Category top10Category:top10CategoryList) { // 遍历传入的Top10Category对象列表
+ Object[] params=new Object[]{ // 创建一个对象数组，用于存储当前Top10Category对象的属性值
+ top10Category.getTaskId(), // 获取任务ID
+ top10Category.getCategoryId(), // 获取分类ID
+ top10Category.getClickCount(), // 获取点击次数
+ top10Category.getOrderCount(), // 获取订单次数
+ top10Category.getPayCount() // 获取支付次数
};
- paramList.add(params);
+ paramList.add(params); // 将参数数组添加到列表中
}
-
- JDBCHelper.getInstance().excuteBatch(sql,paramList);
+ JDBCHelper.getInstance().excuteBatch(sql,paramList); // 调用JDBCHelper的excuteBatch方法执行批量SQL更新（注意：这里应该是executeBatch）
}
-}
+}
\ No newline at end of file
diff --git a/src/main/java/cn/edu/hust/dao/impl/Top10CategorySessionDaoImpl.java b/src/main/java/cn/edu/hust/dao/impl/Top10CategorySessionDaoImpl.java
index 78849a4..2207e26 100644
--- a/src/main/java/cn/edu/hust/dao/impl/Top10CategorySessionDaoImpl.java
+++ b/src/main/java/cn/edu/hust/dao/impl/Top10CategorySessionDaoImpl.java
@@ -1,24 +1,28 @@
-package cn.edu.hust.dao.impl;
+package cn.edu.hust.dao.impl; // 定义包名，表示这个类属于cn.edu.hust.dao.impl包
-import cn.edu.hust.dao.Top10CategorySessionDao;
-import cn.edu.hust.domain.Top10CategorySession;
-import cn.edu.hust.jdbc.JDBCHelper;
+import cn.edu.hust.dao.Top10CategorySessionDao; // 导入Top10CategorySessionDao接口
+import cn.edu.hust.domain.Top10CategorySession; // 导入Top10CategorySession实体类
+import cn.edu.hust.jdbc.JDBCHelper; // 导入JDBCHelper类，用于数据库操作
-import java.util.ArrayList;
-import java.util.List;
+import java.util.ArrayList; // 导入ArrayList类，用于创建列表
+import java.util.List; // 导入List接口
-public class Top10CategorySessionDaoImpl implements Top10CategorySessionDao
+public class Top10CategorySessionDaoImpl implements Top10CategorySessionDao // 定义Top10CategorySessionDaoImpl类，实现Top10CategorySessionDao接口
{
- @Override
- public void batchInsert(List top10CategorySessionList) {
- String sql="insert into top10_category_session values(?,?,?,?)";
- List paramList=new ArrayList();
- for(Top10CategorySession top10CategorySession:top10CategorySessionList)
+ @Override // 覆盖接口中的方法
+ public void batchInsert(List top10CategorySessionList) { // 定义batchInsert方法，用于批量插入Top10CategorySession对象
+ String sql="insert into top10_category_session values(?,?,?,?)"; // 定义插入SQL语句
+ List paramList=new ArrayList(); // 创建一个列表，用于存储每个Top10CategorySession对象的参数数组
+ for(Top10CategorySession top10CategorySession:top10CategorySessionList) // 遍历传入的Top10CategorySession对象列表
{
- Object[] param=new Object[]{top10CategorySession.getTaskId(),top10CategorySession.getCategoryId(),
- top10CategorySession.getSessionId(),top10CategorySession.getClickCount()};
- paramList.add(param);
+ Object[] param=new Object[]{ // 创建一个对象数组，用于存储当前Top10CategorySession对象的属性值
+ top10CategorySession.getTaskId(), // 获取任务ID
+ top10CategorySession.getCategoryId(), // 获取分类ID
+ top10CategorySession.getSessionId(), // 获取会话ID
+ top10CategorySession.getClickCount() // 获取点击次数
+ };
+ paramList.add(param); // 将参数数组添加到列表中
}
- JDBCHelper.getInstance().excuteBatch(sql,paramList);
+ JDBCHelper.getInstance().excuteBatch(sql,paramList); // 调用JDBCHelper的excuteBatch方法执行批量SQL更新（注意：这里应该是executeBatch）
}
-}
+}
\ No newline at end of file