如何防止重复数据插入C#ASP.NET中的Gridview

如何解决如何防止重复数据插入C#ASP.NET中的Gridview

  1. 我有一个如下的表格视图:
EQP       LOT_ID        ACTIVITY            MSG                     MODIFIED_DATE     
001      WM31960       LOAD_LOT         Load lot success.         9/29/2020 11:11:17 AM
001      WM31799       UNLOAD_LOT       Unload lot success.       9/29/2020 11:10:48 AM
001      WM31799       LOAD_LOT         Load lot success.         9/29/2020 6:03:50 AM
001      WM31964       UNLOAD_LOT       Unload lot success.       9/29/2020 6:02:42 AM
002      WM32295       LOAD_LOT         Load lot success.         9/29/2020 11:23:22 AM
002      WM32344       UNLOAD_LOT       Unload lot success.       9/29/2020 11:22:54 AM
002      WM32344       LOAD_LOT         Load lot success          9/29/2020 8:18:18 AM
002      WM32314       UNLOAD_LOT       Unload lot success.       9/29/2020 8:17:55 AM

2。我想使该表成为每个EQP仅获得一行,并且我将对LOT_ID求和如下: (计算)TotalLOT_ID(SUM)=如果LOT_ID = WM31960并且MSG =装载批次成功。

 EQP            TotalLOT_ID                          
 001               2
 002               2
  1. 这是我的编码,但是我没有想要的 Gridview输出
    public void btn_ClickSubmit(object sender,EventArgs e)
      {
            string oradb1 = "Data Source=(DESCRIPTION =" +
          "(ADDRESS = (PROTOCOL=TCP)(HOST = vpngprdrmstmp)(PORT = xxxx))" +
          "(CONNECT_DATA =" +
          "(SERVER = DEDICATED)" +
          "(SERVICE_NAME = xxxxxx)" +
           ")" +
           ");User ID=xxxxxx;Password=xxxxx;";
    
    
            DateTime StartDate = Convert.ToDateTime(datepickerstart.Text);
            string Date = StartDate.ToString("dd-MMM-yyyy");
    
            DateTime EndDate = Convert.ToDateTime(datepicker.Text);
            string dt2 = EndDate.ToString("dd-MMM-yyyy");
    
            string query = "SELECT DISTINCT RMSTMP_PNG.ota_activity.EQP from RMSTMP_PNG.ota_activity FULL OUTER JOIN RMSTMP_PNG.ota_activity_rescreen ON RMSTMP_PNG.ota_activity.ID = RMSTMP_PNG.ota_activity_rescreen.ID FULL OUTER JOIN RMSTMP_PNG.ota_activity_lotinfo ON RMSTMP_PNG.ota_activity.ID = RMSTMP_PNG.ota_activity_lotinfo.ID WHERE RMSTMP_PNG.ota_activity.MODIFIED_DATE >= to_date('" + Date + "')AND RMSTMP_PNG.ota_activity.MODIFIED_DATE < to_date('" + dt2 + "') + 1  ORDER BY RMSTMP_PNG.ota_activity.EQP ASC";
    
            DataTable dt = new DataTable();
    
           
            using (OracleConnection con = new OracleConnection(oradb1))
            {
                using (OracleCommand cmd = new OracleCommand(query))
                {
                    using (OracleDataAdapter sda = new OracleDataAdapter())
                    {
                        cmd.CommandType = CommandType.Text;
                        cmd.Connection = con;
                        sda.SelectCommand = cmd;
                        sda.Fill(dt);
    
                    }
    
                    DataTable da = new DataTable();
                    da.Columns.Add("TEST",typeof(System.String));
                   
                    foreach (DataRow sd in dt.Rows)
                    {
                         
                        
                        var EQP_ID = sd["EQP"].ToString();
           
                        using (OracleConnection conn = new OracleConnection(oradb1))
                        {
    
                           using (OracleCommand cmd1 = new OracleCommand("SELECT RMSTMP_PNG.ota_activity.EQP,RMSTMP_PNG.ota_activity.LOT_ID,RMSTMP_PNG.ota_activity.ACTIVITY,RMSTMP_PNG.ota_activity.MSG,RMSTMP_PNG.ota_activity.MODIFIED_DATE FROM RMSTMP_PNG.ota_activity FULL OUTER JOIN RMSTMP_PNG.ota_activity_rescreen ON RMSTMP_PNG.ota_activity.ID = RMSTMP_PNG.ota_activity_rescreen.ID FULL OUTER JOIN RMSTMP_PNG.ota_activity_lotinfo ON RMSTMP_PNG.ota_activity.ID = RMSTMP_PNG.ota_activity_lotinfo.ID WHERE RMSTMP_PNG.ota_activity.MODIFIED_DATE >= to_date('" + Date + "')AND RMSTMP_PNG.ota_activity.MODIFIED_DATE < to_date('" + dt2 + "') + 1 AND EQP ='" + EQP_ID + "' GROUP BY RMSTMP_PNG.ota_activity.LOT_ID,RMSTMP_PNG.ota_activity.MODIFIED_DATE,RMSTMP_PNG.ota_activity.ID ORDER BY RMSTMP_PNG.ota_activity.EQP,RMSTMP_PNG.ota_activity.MODIFIED_DATE DESC"))
                           
    
                            {
                                using (OracleDataAdapter sda1 = new OracleDataAdapter())
                                {
    
                                    cmd1.CommandType = CommandType.Text;
                                    cmd1.Connection = conn;
                                    sda1.SelectCommand = cmd1;
                                    sda1.Fill(da);
                                }
                                                                            
                            }
    
                            
                            DataRow prevRow = null;
                            
    
                            foreach (DataRow sda2 in da.Rows)
                            {
    
                                var eq = sda2["EQP"].ToString();
    
                                if (prevRow != null)
                                {
                                    if ( prevRow.Field<string>("EQP") != eq)
                                    {
    
                                        var eq1= sda2["EQP"].ToString();                                    
                                        sda2["TEST"] = eq1;
                                        
                                    }
                                    else
                                    {
                                        var eq2 = sda2["EQP"].ToString();
                                        
                                    }
                                }
                                prevRow = sda2;
    
                            }
    
                        
                            GridView2.DataSource = da;
                            GridView2.DataBind();
                           
                        }
                    }
                }
            }
        }

能不能给我一些提示或我可以尝试什么?

  1. 最新更新的代码如下(在内部添加了一些注释,希望您能理解我的意思):

     public void btn_ClickSubmit(object sender,EventArgs e)
         {
             string oradb1 = "Data Source=(DESCRIPTION =" +
    

    ”(广告

     DRESS = (PROTOCOL=TCP)(HOST = vpngprdrmstmp)(PORT = 1548))" +
           "(CONNECT_DATA =" +
           "(SERVER = DEDICATED)" +
           "(SERVICE_NAME = rmstmpdb)" +
            ")" +
            ");User ID=OTA_VIEW;Password=0taV1ew;";
    
    
             DateTime StartDate = Convert.ToDateTime(datepickerstart.Text);
             string Date = StartDate.ToString("dd-MMM-yyyy");
    
             DateTime EndDate = Convert.ToDateTime(datepicker.Text);
             string dt2 = EndDate.ToString("dd-MMM-yyyy");
    
             //Get the list of EQP use DISTINCT 
             string query = "SELECT DISTINCT RMSTMP_PNG.ota_activity.EQP from RMSTMP_PNG.ota_activity FULL OUTER JOIN RMSTMP_PNG.ota_activity_rescreen ON RMSTMP_PNG.ota_activity.ID = RMSTMP_PNG.ota_activity_rescreen.ID FULL OUTER JOIN RMSTMP_PNG.ota_activity_lotinfo ON RMSTMP_PNG.ota_activity.ID = RMSTMP_PNG.ota_activity_lotinfo.ID WHERE RMSTMP_PNG.ota_activity.MODIFIED_DATE >= to_date('" + Date + "')AND RMSTMP_PNG.ota_activity.MODIFIED_DATE < to_date('" + dt2 + "') + 1  ORDER BY RMSTMP_PNG.ota_activity.EQP_ID ASC";
    
             DataTable dt = new DataTable();
    
    
             using (OracleConnection con = new OracleConnection(oradb1))
             {
                 using (OracleCommand cmd = new OracleCommand(query))
                 {
                     using (OracleDataAdapter sda = new OracleDataAdapter())
                     {
                         cmd.CommandType = CommandType.Text;
                         cmd.Connection = con;
                         sda.SelectCommand = cmd;
                         sda.Fill(dt);
    
                     }
    
                     DataTable da = new DataTable();
                     da.Columns.Add("EQP",typeof(string));
                     da.Columns.Add("TotalLOT_ID",typeof(string));
    
    
                     foreach (DataRow sd in dt.Rows)
                     {
    
                  //Once get the EQP,then run the query with many data column.
                         var EQP_ID = sd["EQP"].ToString();
    
    
                         using (OracleConnection conn = new OracleConnection(oradb1))
                         {
    
                             using (OracleCommand cmd1 = new OracleCommand("SELECT RMSTMP_PNG.ota_activity.EQP,RMSTMP_PNG.ota_activity.MESSAGE,LISTAGG (RMSTMP_PNG.ota_activity_lotinfo.KEY  || ': ' || RMSTMP_PNG.ota_activity_lotinfo.VALUE,','||chr(13)||chr(10)) WITHIN GROUP (ORDER BY RMSTMP_PNG.ota_activity_lotinfo.KEY,RMSTMP_PNG.ota_activity_lotinfo.VALUE) AS names,TO_CHAR (DATE '1900-01-01' + ABS ( LAG(RMSTMP_PNG.ota_activity.MODIFIED_DATE,1)OVER(ORDER BY RMSTMP_PNG.ota_activity.MODIFIED_DATE DESC)  - RMSTMP_PNG.ota_activity.MODIFIED_DATE),'HH24:MI:SS') AS Time_Different FROM RMSTMP_PNG.ota_activity FULL OUTER JOIN RMSTMP_PNG.ota_activity_rescreen ON RMSTMP_PNG.ota_activity.ID = RMSTMP_PNG.ota_activity_rescreen.ID FULL OUTER JOIN RMSTMP_PNG.ota_activity_lotinfo ON RMSTMP_PNG.ota_activity.ID = RMSTMP_PNG.ota_activity_lotinfo.ID WHERE RMSTMP_PNG.ota_activity.MODIFIED_DATE >= to_date('" + Date + "')AND RMSTMP_PNG.ota_activity.MODIFIED_DATE < to_date('" + dt2 + "') + 1 AND EQP ='" + EQP_ID + "' GROUP BY RMSTMP_PNG.ota_activity.LOT_ID,RMSTMP_PNG.ota_activity_lotinfo.KEY,RMSTMP_PNG.ota_activity_lotinfo.VALUE,RMSTMP_PNG.ota_activity.EQP_ID ORDER BY RMSTMP_PNG.ota_activity.EQP_ID,RMSTMP_PNG.ota_activity.MODIFIED_DATE DESC"))
    
    
                             {
                                 using (OracleDataAdapter sda1 = new OracleDataAdapter())
                                 {
    
                                     cmd1.CommandType = CommandType.Text;
                                     cmd1.Connection = conn;
                                     sda1.SelectCommand = cmd1;
                                     sda1.Fill(da);
                                 }
    
    
                //Once get the first EQP then loop to display data in GRIDVIEW             
    
                foreach (DataRow sda2 in da.Rows)
                                 {
                                     var eqp = sda2["EQP"].ToString();
                                     var lotid = sda2["LOT_ID"].ToString();
                                     var msg = sda2["MSG"].ToString();
    
                                     if (lotid.Equals(lotid) && msg.Equals("Load lot success."))
                                     {
                                         string query1 = string.Format("EQP='{0}'",eqp.Replace(@"'","''"));
                                         var rows = da.Select(query1);
    
                                         if (rows.Length > 0)
                                         {
                                             var rowIndex = da.Rows.IndexOf(rows[0]);
                                             da.Rows[rowIndex]["TotalLOT_ID"] = int.Parse(da.Rows[rowIndex]["TotalLOT_ID"].ToString()) + 1;
                                         }
                                         else
                                         {
                                             if (lotid.Equals(lotid) && msg.Equals("Load lot success."))
                                             {
                                                 da.Rows.Add(eqp,1);
                                             }
                                         }
                                     }
                                 }
    
                                 GridView2.DataSource = da;
                                 GridView2.DataBind();
    
    
    
    
                            }
                         }
                     }
                 }
             }
         }
    

(更新:我更改了查询,表格视图如下所示)。

EQP       LOT        ACTIVITY            MSG                  MODIFIED_DATE 
001     WM34163      LOAD_LOT          Load lot success.      10/01/2020 11:11:11
001     WM34163      LOAD_LOT          Load lot success.      10/01/2020 11:11:11
001     WM34163      LOAD_LOT          Load lot success.      10/01/2020 11:11:11
001     WM34163      LOAD_LOT          Load lot success.      10/01/2020 11:11:11
001     WM34163      CANCEL_LOT        CANCEL.                10/01/2020 12:11:11
001     WM34160      UNLOAD_LOT        Unload lot success.    10/01/2020 13:10:12
001     WM34160      UNLOAD_LOT        Unload lot success.    10/01/2020 13:10:12
002     WM32439      LOAD_LOT          Load lot success.      10/01/2020 15:11:12
002     WM32439      LOAD_LOT          Load lot success.      10/01/2020 15:11:12
002     WM32439      LOAD_LOT          Load lot success.      10/01/2020 15:11:12

(我想只得到1 = WM34163和WM32439 = 1,因为它们是重复的Lot_id,但现在算作4) 一旦运行了后端代码,它将显示如下。

ID        Total_LOTID
001          4  
002          3

这是我最新的编码。我不知道在哪里应用我的foreach循环(总和)以避免被删除。

foreach (DataRow sda2 in da.Rows)
     {
                            var totalsum = 0;
                            DataRow prevRow = null;
                            var eqp = sda2["EQP_ID"].ToString();
                            var lot = sda2["T"].ToString();
                            var lotid = sda2["LOT_ID"].ToString();                           
                            int sum = 0;
                         

                            foreach (DataRow sa in da.Rows)
                            {
                                if (prevRow != null)
                                {
                                    var display = prevRow["LOT_ID"].ToString();
                                    if (lotid != prevRow["LOT_ID"].ToString() && lotid.Equals("1"))
                                    {
                                        sum++;

                                    }
                                }
                                prevRow = sa;
                            }
                            totalsum = sum;
                       

                            if (lot.Equals(lot))
                              {
                                string query2 = string.Format("EQP='{0}'","''"));
                                var rows = dx.Select(query2);

                                if (rows.Length > 0)
                                 {
                                    var rowIndex = dx.Rows.IndexOf(rows[0]);
                                       
                                      dx.Rows[rowIndex]["TotalLOT_ID"] = totalsum;

                                 }
                                else
                                {
                                    
                                    if (lot.Equals(lot))
                                    {
                                        dx.Rows.Add(eqp,1);
                                    }
                                }
                            }
                        }

解决方法

public void btn_ClickSubmit(object sender,EventArgs e)
{
    using (OracleCommand cmd = new OracleCommand(query))
        {
            using (OracleDataAdapter sda = new OracleDataAdapter())
            {
                cmd.CommandType = CommandType.Text;
                cmd.Connection = con;
                sda.SelectCommand = cmd;
                sda.Fill(dt);

            }

            DataTable da = new DataTable();

            // Create another DT to store final result
            DataTable dx = new DataTable();
            dx.Columns.Add("EQP",typeof(string));
            dx.Columns.Add("TotalLOT_ID",typeof(string));

            foreach (DataRow sd in dt.Rows)
            {
                //Once get the EQP,then run the query with many data column.
                var EQP_ID = sd["EQP"].ToString();

                using (OracleConnection conn = new OracleConnection(oradb1))
                {
                    using (OracleCommand cmd1 = new OracleCommand("SELECT RMSTMP_PNG.ota_activity.EQP,RMSTMP_PNG.ota_activity.LOT_ID,RMSTMP_PNG.ota_activity.ACTIVITY,RMSTMP_PNG.ota_activity.MESSAGE,LISTAGG (RMSTMP_PNG.ota_activity_lotinfo.KEY  || ': ' || RMSTMP_PNG.ota_activity_lotinfo.VALUE,','||chr(13)||chr(10)) WITHIN GROUP (ORDER BY RMSTMP_PNG.ota_activity_lotinfo.KEY,RMSTMP_PNG.ota_activity_lotinfo.VALUE) AS names,RMSTMP_PNG.ota_activity.MODIFIED_DATE,TO_CHAR (DATE '1900-01-01' + ABS ( LAG(RMSTMP_PNG.ota_activity.MODIFIED_DATE,1)OVER(ORDER BY RMSTMP_PNG.ota_activity.MODIFIED_DATE DESC)  - RMSTMP_PNG.ota_activity.MODIFIED_DATE),'HH24:MI:SS') AS Time_Different FROM RMSTMP_PNG.ota_activity FULL OUTER JOIN RMSTMP_PNG.ota_activity_rescreen ON RMSTMP_PNG.ota_activity.ID = RMSTMP_PNG.ota_activity_rescreen.ID FULL OUTER JOIN RMSTMP_PNG.ota_activity_lotinfo ON RMSTMP_PNG.ota_activity.ID = RMSTMP_PNG.ota_activity_lotinfo.ID WHERE RMSTMP_PNG.ota_activity.MODIFIED_DATE >= to_date('" + Date + "')AND RMSTMP_PNG.ota_activity.MODIFIED_DATE < to_date('" + dt2 + "') + 1 AND EQP ='" + EQP_ID + "' GROUP BY RMSTMP_PNG.ota_activity.LOT_ID,RMSTMP_PNG.ota_activity_lotinfo.KEY,RMSTMP_PNG.ota_activity_lotinfo.VALUE,RMSTMP_PNG.ota_activity.EQP_ID ORDER BY RMSTMP_PNG.ota_activity.EQP_ID,RMSTMP_PNG.ota_activity.MODIFIED_DATE DESC"))
                    {
                        using (OracleDataAdapter sda1 = new OracleDataAdapter())
                        {

                            cmd1.CommandType = CommandType.Text;
                            cmd1.Connection = conn;
                            sda1.SelectCommand = cmd1;
                            sda1.Fill(da);
                        }
                    }

                    foreach (DataRow sda2 in da.Rows)
                    {
                        var eqp = sda2["EQP"].ToString();
                        var lotid = sda2["LOT_ID"].ToString();
                        var msg = sda2["MSG"].ToString();

                        if (lotid.Equals("WM31960") && msg.Equals("Load lot success."))
                        {
                            string query2 = string.Format("EQP='{0}'",eqp.Replace(@"'","''"));
                            var rows = dx.Select(query2);

                            if (rows.Length > 0)
                            {
                                var rowIndex = dx.Rows.IndexOf(rows[0]);
                                dx.Rows[rowIndex]["TotalLOT_ID"] = int.Parse(dx.Rows[rowIndex]["TotalLOT_ID"].ToString()) + 1;
                            }
                            else
                            {
                                if (lotid.Equals("WM31960") && msg.Equals("Load lot success."))
                                {
                                    dx.Rows.Add(eqp,1);
                                }
                            }
                        }
                    }
                }
            }

            GridView2.DataSource = dx;
            GridView2.DataBind();
        }
    }
}

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


依赖报错 idea导入项目后依赖报错,解决方案:https://blog.csdn.net/weixin_42420249/article/details/81191861 依赖版本报错:更换其他版本 无法下载依赖可参考:https://blog.csdn.net/weixin_42628809/a
错误1:代码生成器依赖和mybatis依赖冲突 启动项目时报错如下 2021-12-03 13:33:33.927 ERROR 7228 [ main] o.s.b.d.LoggingFailureAnalysisReporter : *************************** APPL
错误1:gradle项目控制台输出为乱码 # 解决方案:https://blog.csdn.net/weixin_43501566/article/details/112482302 # 在gradle-wrapper.properties 添加以下内容 org.gradle.jvmargs=-Df
错误还原:在查询的过程中,传入的workType为0时,该条件不起作用 &lt;select id=&quot;xxx&quot;&gt; SELECT di.id, di.name, di.work_type, di.updated... &lt;where&gt; &lt;if test=&qu
报错如下,gcc版本太低 ^ server.c:5346:31: 错误:‘struct redisServer’没有名为‘server_cpulist’的成员 redisSetCpuAffinity(server.server_cpulist); ^ server.c: 在函数‘hasActiveC
解决方案1 1、改项目中.idea/workspace.xml配置文件,增加dynamic.classpath参数 2、搜索PropertiesComponent,添加如下 &lt;property name=&quot;dynamic.classpath&quot; value=&quot;tru
删除根组件app.vue中的默认代码后报错:Module Error (from ./node_modules/eslint-loader/index.js): 解决方案:关闭ESlint代码检测,在项目根目录创建vue.config.js,在文件中添加 module.exports = { lin
查看spark默认的python版本 [root@master day27]# pyspark /home/software/spark-2.3.4-bin-hadoop2.7/conf/spark-env.sh: line 2: /usr/local/hadoop/bin/hadoop: No s
使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams[&#39;font.sans-serif&#39;] = [&#39;SimHei&#39;] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -&gt; systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping(&quot;/hires&quot;) public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate&lt;String
使用vite构建项目报错 C:\Users\ychen\work&gt;npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-