是的,您只能使用 SQL 来执行此操作。一个解决方案是使用存储例程。下面的存储过程产生以下输出:
start cnt
00:05:00 1
00:10:00 0
00:15:00 1
00:20:00 0
00:25:00 1
00:30:00 0
00:35:00 1
00:40:00 0
00:45:00 0
00:50:00 0
00:55:00 2
我使用的表格:
CREATE TABLE `timedata` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`c1` datetime DEFAULT NULL,
`c2` varchar(20) DEFAULT NULL,
PRIMARY KEY (`id`)
)
这里是存储过程(根据您的环境进行调整):
DROP PROCEDURE IF EXISTS per5min;
DELIMITER //
CREATE PROCEDURE per5min ()
BEGIN
DECLARE dtMin DATETIME;
DECLARE dtMax DATETIME;
DECLARE dtStart DATETIME;
DECLARE dtStop DATETIME;
DECLARE tmDiff TIME;
DECLARE result INT UNSIGNED;
SET @offset = 5 * 60;
SELECT MIN(c1) into dtMin FROM timedata;
SELECT MAX(c1) into dtMax FROM timedata;
CREATE TEMPORARY TABLE tmp_per5min (
start TIME,
cnt INT UNSIGNED
);
SET dtStart = dtMin;
REPEAT
SELECT dtStart + INTERVAL @offset SECOND into dtStop;
SELECT count(c2) into result FROM timedata WHERE c1 BETWEEN dtStart and dtStop;
SELECT TIME(SUBTIME(dtStop,TIME(dtMin))) into tmDiff;
INSERT INTO tmp_per5min (start,cnt) VALUES (tmDiff,result);
SET dtStart = dtStop;
UNTIL dtStop >= dtMax END REPEAT;
SELECT * FROM tmp_per5min;
DROP TABLE tmp_per5min;
END;
//
DELIMITER ;
CALL per5min();
如果将上述内容保存到名为“per5minproc.sql”的文件中,则可以这样加载:
shell> mysql -uroot test < per5minproc.sql
在 Python 中使用 MySQLdb(我没有在 MySQL Connector/Python 中得到这个工作,我很惭愧!):
import MySQLdb as m
if __name__ == '__main__':
db = m.connect(user='root',db='test')
c = db.cursor()
c.callproc("per5min")
print(c.fetchall())
c.close()
db.close()
上述解决方案有效,但可能需要一些调整,例如dtStart 可以是 SP 的参数。
而且,确实都是 SQL!