vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-05-01 00:19:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Added DB utils

Browse source
This commit is contained in:
Luca Deri 2015-08-16 19:36:45 +02:00
parent e59d699837
commit a16ca6600d
1 changed files with 44 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

44
scripts/lua/modules/db_utils.lua Normal file
View file

@ -0,0 +1,44 @@
--
-- (C) 2014-15 - ntop.org
--
dirs = ntop.getDirs()
package.path = dirs.installdir .. "/scripts/lua/modules/?.lua;" .. package.path
require "template"
local db_debug = false
--- ====================================================================
function getInterfaceTopFlows(interface_id, version, begin_epoch, end_epoch, offset, max_num_flows, sort_column, sort_order)
-- CONVERT(UNCOMPRESS(JSON) USING 'utf8') AS JSON
sql = "select INET_NTOA(IPV4_SRC_ADDR) AS IPV4_SRC_ADDR,INET_NTOA(IPV4_DST_ADDR) AS IPV4_DST_ADDR,L4_SRC_PORT,L4_DST_PORT,VLAN_ID,PROTOCOL,FIRST_SWITCHED,LAST_SWITCHED,PACKETS,BYTES,idx,L7_PROTO from flowsv"..version.."_"..interface_id.." where FIRST_SWITCHED <= "..end_epoch.." and FIRST_SWITCHED >= "..begin_epoch.." order by "..sort_column.." "..sort_order.." limit "..max_num_flows.." OFFSET "..offset
if(db_debug == true) then io.write(sql.."\n") end
res = interface.execSQLQuery(sql)
if(type(res) == "string") then
if(db_debug == true) then io.write(res.."\n") end
return nil
else
return(res)
end
end
--- ====================================================================
function getInterfaceFlows(interface_id, version, host, vlan, begin_epoch, end_epoch, limit_low, limit_high)
end
--- ====================================================================
function getHostTopFlows(interface_id, version, host, vlan, begin_epoch, end_epoch, max_num_flows)
end
--- ====================================================================
function getHostFlows(interface_id, version, host, vlan, begin_epoch, end_epoch, limit_low, limit_high)
end