Модератор: terminus
Код: Выделить всё
ALTER TABLE `data` ADD `data_add` DATE NOT NULL DEFAULT 'now()' AFTER `user`
Код: Выделить всё
ALTER TABLE `data` ADD `data_add` DATE NULL DEFAULT 'now()' AFTER `user`
etc....Пусть MySQL автоматически установит значение столбца с типом TIMESTAMP при создании данной строки. Столбец будет установлен в исходное состояние со значением текущих даты и времени.
При выполнении последующих обновлений других столбцов в данной строке необходимо явно установить столбец TIMESTAMP в его текущее значение.
Однако, с другой стороны, для этих целей, возможно, будет проще использовать столбец DATETIME. При создании строки его следует инициализировать функцией NOW() и оставить в покое при последующих обновлениях.
Как результат выполнения функции, возвращающей величину, приемлемую в контекстах типов данных DATETIME, DATE или TIMESTAMP (например, функции NOW() или CURRENT_DATE).
Недопустимые значения величин DATETIME, DATE или TIMESTAMP преобразуются в значение ``ноль'' соответствующего типа величин ('0000-00-00 00:00:00', '0000-00-00', или 00000000000000).
Код: Выделить всё
CREATE TABLE `data` (
`doctets` int(11) NOT NULL,
`srcaddr` text NOT NULL,
`dstaddr` text NOT NULL,
`srcport` int(11) NOT NULL,
`dstport` int(11) NOT NULL,
`data_add` timestamp NOT NULL default CURRENT_TIMESTAMP
) ENGINE=MyISAM DEFAULT CHARSET=utf8;
Код: Выделить всё
INSERT INTO `data` (`doctets`, `srcaddr`, `dstaddr`, `srcport`, `dstport`, `data_add`) VALUES
(131, '192.168.2.2', '80.121.89.67', 64525, 16945, '2010-01-13 13:29:07'),
пока потом разберусь что к чему и с какогот TIMESTAMP
это значит, что логам не место в базеGamerman писал(а):что сие значит?
Оо!!! с netflow-export знакомы?Код: Выделить всё
OFFTOP2010-01-13 13:29:07 . 0000-00-00 00:00:00Gamerman писал(а):Какой формат?
Код: Выделить всё
SELECT (SUM( doctets ))/8192 AS sdoctets, `srcport`
FROM `data`
WHERE `dstaddr` = '192.168.2.2' AND `data_add` > DATE_SUB(NOW(), INTERVAL 1 DAY)
GROUP BY `data`.`srcport`
ORDER BY `sdoctets` DESC
LIMIT 0 , 10
Код: Выделить всё
2355888.3354 80
11131.6691 56712
8278.0594 18768
7996.6954 23206
7913.1682 64258
7589.6412 48601
6791.8517 20253
5115.1610 16567
4724.0021 20829
3208.8488 48437
если в базе лог только за сутки, то зачем это условие?agat писал(а):логам место в базе на сутки.
agat писал(а):AND `data_add` > DATE_SUB(NOW(), INTERVAL 1 DAY)
ЕМНИП только так:agat писал(а):Как создать поле что бы в него без явного указания в запросе запихивать дату и время
Код: Выделить всё
ALTER TABLE foo ADD bar timestamp on update CURRENT_TIMESTAMP;Код: Выделить всё
DROP DATABASE IF EXISTS netflow;
CREATE DATABASE netflow DEFAULT CHARACTER SET koi8r COLLATE koi8r_general_ci;
-- --------------------------------------------------------
CREATE TABLE raw (
unix_secs int(10) unsigned NOT NULL default '0',
dpkts int(10) unsigned NOT NULL default '0',
doctets int(10) unsigned NOT NULL default '0',
srcaddr varchar(45) NOT NULL default '0',
dstaddr varchar(45) NOT NULL default '0',
srcport smallint(5) unsigned NOT NULL default '0',
dstport smallint(5) unsigned NOT NULL default '0',
prot tinyint(3) unsigned NOT NULL default '0'
) TYPE=MyISAM;
-- --------------------------------------------------------
CREATE TABLE raw_data (
unix_secs int(10) unsigned NOT NULL default '0',
src_ip int(10) unsigned NOT NULL default '0',
dst_ip int(10) unsigned NOT NULL default '0',
packets int(10) unsigned NOT NULL default '0',
bytes int(10) unsigned NOT NULL default '0',
src_port smallint(5) unsigned NOT NULL default '0',
dst_port smallint(5) unsigned NOT NULL default '0',
proto tinyint(3) unsigned NOT NULL default '0',
KEY scr_idx (src_ip,dst_port),
KEY time_idx (unix_secs)
) TYPE=MyISAM;
Код: Выделить всё
#!/bin/sh
flow_base="/path/to/netflow/flows"
flow_dir="$flow_base/`date -v -1m +%Y/%Y-%m`"
#flow_dir="$flow_base/2003/2003-12"
tmp_file="$flow_base/tmp.csv"
flow_export="/usr/local/bin/flow-export"
mysql_user='root'
mysql_pass='root'
mysql="/usr/local/bin/mysql -u $mysql_user -p$mysql_pass "
if [ -d $flow_dir ]; then
for i in `ls -1 $flow_dir | grep ^ft-`; do
if [ -r $flow_file_in ]; then
$flow_export -f 2 -m UNIX_SECS,DFLOWS,DPKTS,DOCTETS,SRCADDR,DSTADDR,SRCPORT,DSTPORT,PROT < $flow_dir/$i > $tmp_file
fi
if [ -r $tmp_file ]; then
$mysql -D netflow -B -e "LOAD DATA INFILE '$tmp_file' INTO TABLE raw FIELDS TERMINATED BY ',' ENCLOSED BY '' LINES TERMINATED BY '\n'; DELETE FROM raw WHERE srcaddr = 'srcaddr' AND dstaddr = 'dstaddr'; INSERT INTO raw_data SELECT unix_secs, INET_ATON(srcaddr), INET_ATON(dstaddr), dpkts, doctets, srcport, dstport, prot FROM raw; TRUNCATE TABLE raw;"
rm -f $tmp_file
fi
done
fi