mysql - 在插入时启动触发器和例程

标签 mysql sql triggers routines

我试图让 MySQL 在插入一个表后自动将数据插入另一个表。我知道这样做需要触发器和潜在的例程。我有一对夫妇,我一直在尝试修改以完成我希望完成的事情,但由于缺乏经验,我似乎陷入了死胡同,因此非常感谢您的帮助。

插入数据的表(db_tou_tracking):

 tou_tracking_ID  ICP_ID  tou_tracking_start  tou_tracking_units
 ----------------------------------------------------------------
      2             2        2013-03-01            10.77
      3             2        2013-03-01            11.00

这里还有几个其他的列,它们按时间分开,但我感兴趣的是按天而不是时间。

表数据应该复合。因此,在插入上述每一行时,如果 tou_tracking_start 和 ICP_ID 不存在,它将创建一个新行,或者更新现有行。

  tou_tracking_daily_ID  ICP_ID  tou_tracking_start  tou_tracking_units
 ------------------------------------------------------------------------------
             1             2        2013-03-01            21.77
             2             2        2013-03-02            25.36

下面是我的 Tigger(在 MySQL 上设置时没有错误,并且在尝试插入数据时它确实会调用):

BEGIN 
DECLARE presentcount INT;
SET presentcount = (SELECT count(*) FROM db_tou_tracking_daily WHERE tou_tracking_daily_day = 
        (SELECT tou_tracking_start FROM db_tou_tracking WHERE ICP_ID = db_tou_tracking_daily.ICP_ID ORDER BY tou_tracking_ID DESC)
    );
    IF (presentcount = 0) THEN
        INSERT INTO db_tou_tracking_daily (ICP_ID, tou_tracking_daily_day, tou_tracking_start)
            SELECT NEW.ICP_ID, NEW.tou_tracking_start, NEW.tou_tracking_units, calculate_units(NEW.ICP_ID, NEW.tou_tracking_start);
    ELSE 
        UPDATE db_tou_tracking_daily SET tou_tracking_daily_units = calculate_units(NEW.ICP_ID, tou_tracking_daily_day)
            WHERE ICP_ID = NEW.ICP_ID AND tou_tracking_daily_day = NEW.tou_tracking_start;
    END IF;

END

然后它调用计算单位的例程。

    CREATE DEFINER=`root`@`localhost` FUNCTION `calculate_units`(ICP_ID INT, tou_tracking_daily_day DATE) RETURNS float
BEGIN
    DECLARE units FLOAT;
    DECLARE last_time DATE;
    DECLARE last_watts INT;
    DECLARE this_time DATETIME;
    DECLARE this_watts INT;
    DECLARE loop_done INT;
    DECLARE curs CURSOR FOR 
        SELECT tou_tracking_timestart, tou_tracking_units FROM db_tou_tracking WHERE ICP_ID = ICP_ID AND tou_tracking_start = tou_tracking_daily_day ORDER BY tou_tracking_start DESC;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET loop_done = 1;

        SET last_time = (SELECT max(tou_tracking_start) FROM db_tou_tracking WHERE ICP_ID = ICP_ID AND tou_tracking_start < tou_tracking_daily_day);
        SET last_watts = (SELECT tou_tracking_units FROM db_tou_tracking WHERE ICP_ID = ICP_ID AND tou_tracking_start = last_time);
        SET last_time = CAST(tou_tracking_start AS DATETIME);

        SET loop_done = 0;
        SET units = 0;

        OPEN curs;
        REPEAT
            FETCH curs INTO this_time, this_watts;

            IF last_watts IS NOT NULL THEN
                SET units = units + (last_watts + this_watts);
            END IF;
            SET last_watts = this_watts;
            SET last_time = this_time;
        UNTIL loop_done END REPEAT;
        CLOSE curs;
    END

当我尝试运行 SQL 来设置例程时,例程在第 3 行返回错误,但我看不到任何明显的错误,但我不确定我要寻找什么。

非常感谢您对此提供的任何帮助,并在此过程中提供任何指示。谢谢:)

最佳答案

尝试重现您的问题,我猜您得到的错误可能是因为您没有使用 DELIMITER

执行类似的函数创建语句我得到同样的错误,语法分析表明它不需要分隔符 ;

导致第 3 行错误的那个。

CREATE DEFINER = 'root'@'localhost' FUNCTION test_func(foo INT) RETURNS FLOAT
BEGIN
    DECLARE bar FLOAT;
    RETURN 1;
END

使用定界符修复它。

DELIMITER $$
CREATE DEFINER = 'root'@'localhost' FUNCTION test_func(foo INT) RETURNS FLOAT
BEGIN
    DECLARE bar FLOAT;
    RETURN 1;
END$$
DELIMITER ;

如果这不能解决您的问题,您是否能够提供一个不依赖于任何现有表的自包含函数,它也会产生相同的错误以便对其进行测试?

关于mysql - 在插入时启动触发器和例程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/23530572/

相关文章:

mysql - 数据库访问权限模型

sql - SQL 中 Case 列的乘法

sql - 在 SQL Server 数据库中平均纬度/经度

.net - WPF中有哪些不同的触发器?

javascript - 动态字段的可靠下拉菜单

php - 在 laravel 5.4 中如何编写这个 sql 查询?

sql - 使用编译错误创建的触发器

c# - .Net SqlDataAdapter 和 SQL Server 中的触发器

mysql - 多级查询从第二个子查询获取值来驱动父元素

sql - 使用一张小表的值更新一张大表的性能