Package com.alibaba.druid.support.monitor.dao

Class MonitorDaoJdbcImpl

java.lang.Object

com.alibaba.druid.support.monitor.dao.MonitorDaoJdbcImpl

All Implemented Interfaces:

MonitorDao

public class MonitorDaoJdbcImpl
extends Object
implements MonitorDao

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MonitorDaoJdbcImpl.BeanInfo
static class	MonitorDaoJdbcImpl.FieldInfo

Constructor Summary

Constructors

Constructor	Description
MonitorDaoJdbcImpl()

Method Summary

Modifier and Type	Method	Description
String	buildInsertSql(MonitorDaoJdbcImpl.BeanInfo beanInfo)
boolean	cacheContains(String type, Long hash)
String	cacheGet(String type, Long hash)
void	cachePut(String type, Long hash, String value)
Object	createInstance(MonitorDaoJdbcImpl.BeanInfo beanInfo)
void	createTables(String dbType)
MonitorApp	findApp(String domain, String app)
MonitorCluster	findCluster(String domain, String app, String cluster)
MonitorInstance	findInst(String domain, String app, String cluster, String host)
protected String	getConstValueFromDb(String domain, String app, String type, Long hash)
DataSource	getDataSource()
protected long	getSqlHash(String sql)
String	getTableName(MonitorDaoJdbcImpl.BeanInfo beanInfo)
void	insertAppIfNotExits(String domain, String app)
void	insertClusterIfNotExits(String domain, String app, String cluster)
void	insertOrUpdateInstance(String domain, String app, String cluster, String host, String ip, Date startTime, long pid)
List<MonitorApp>	listApp(String domain)
List<MonitorCluster>	listCluster(String domain, String app)
List<MonitorInstance>	listInst(String domain, String app, String cluster)
List<JdbcSqlStatValue>	loadSqlList(Map<String,Object> filters)
protected void	readFieldValue(Object object, MonitorDaoJdbcImpl.FieldInfo field, ResultSet rs, int paramIndex)
void	saveSpringMethod(MonitorContext ctx, List<SpringMethodStatValue> list)
void	saveSql(MonitorContext ctx, List<DruidDataSourceStatValue> dataSourceList)
void	saveSqlWall(MonitorContext ctx, List<WallProviderStatValue> statList)
void	saveWebApp(MonitorContext ctx, List<WebAppStatValue> list)
void	saveWebURI(MonitorContext ctx, List<WebURIStatValue> list)
void	setDataSource(DataSource dataSource)
protected void	setParameterForSqlStat(MonitorDaoJdbcImpl.BeanInfo beanInfo, MonitorContext ctx, PreparedStatement stmt, Object sqlStat)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MonitorDaoJdbcImpl

public MonitorDaoJdbcImpl()

Method Detail

createTables

public void createTables(String dbType)

getDataSource

public DataSource getDataSource()

setDataSource

public void setDataSource(DataSource dataSource)

saveSql

public void saveSql(MonitorContext ctx,
                    List<DruidDataSourceStatValue> dataSourceList)

Specified by:

saveSql in interface MonitorDao

saveSpringMethod

public void saveSpringMethod(MonitorContext ctx,
                             List<SpringMethodStatValue> list)

Specified by:

saveSpringMethod in interface MonitorDao

saveWebURI

public void saveWebURI(MonitorContext ctx,
                       List<WebURIStatValue> list)

Specified by:

saveWebURI in interface MonitorDao

saveSqlWall

public void saveSqlWall(MonitorContext ctx,
                        List<WallProviderStatValue> statList)

Specified by:

saveSqlWall in interface MonitorDao

saveWebApp

public void saveWebApp(MonitorContext ctx,
                       List<WebAppStatValue> list)

Specified by:

saveWebApp in interface MonitorDao

loadSqlList

public List<JdbcSqlStatValue> loadSqlList(Map<String,Object> filters)

Specified by:

loadSqlList in interface MonitorDao

readFieldValue

protected void readFieldValue(Object object,
                              MonitorDaoJdbcImpl.FieldInfo field,
                              ResultSet rs,
                              int paramIndex)
                       throws SQLException

Throws:

SQLException

getConstValueFromDb

protected String getConstValueFromDb(String domain,
                                     String app,
                                     String type,
                                     Long hash)

setParameterForSqlStat

protected void setParameterForSqlStat(MonitorDaoJdbcImpl.BeanInfo beanInfo,
                                      MonitorContext ctx,
                                      PreparedStatement stmt,
                                      Object sqlStat)
                               throws SQLException

Throws:

SQLException

createInstance

public Object createInstance(MonitorDaoJdbcImpl.BeanInfo beanInfo)

buildInsertSql

public String buildInsertSql(MonitorDaoJdbcImpl.BeanInfo beanInfo)

getTableName

public String getTableName(MonitorDaoJdbcImpl.BeanInfo beanInfo)

getSqlHash

protected long getSqlHash(String sql)

cacheContains

public boolean cacheContains(String type,
                             Long hash)

cacheGet

public String cacheGet(String type,
                       Long hash)

cachePut

public void cachePut(String type,
                     Long hash,
                     String value)

insertAppIfNotExits

public void insertAppIfNotExits(String domain,
                                String app)
                         throws SQLException

Specified by:

insertAppIfNotExits in interface MonitorDao

Throws:

SQLException

listApp

public List<MonitorApp> listApp(String domain)
                         throws SQLException

Throws:

SQLException

findApp

public MonitorApp findApp(String domain,
                          String app)
                   throws SQLException

Throws:

SQLException

listCluster

public List<MonitorCluster> listCluster(String domain,
                                        String app)
                                 throws SQLException

Throws:

SQLException

insertClusterIfNotExits

public void insertClusterIfNotExits(String domain,
                                    String app,
                                    String cluster)
                             throws SQLException

Specified by:

insertClusterIfNotExits in interface MonitorDao

Throws:

SQLException

findCluster

public MonitorCluster findCluster(String domain,
                                  String app,
                                  String cluster)
                           throws SQLException

Throws:

SQLException

insertOrUpdateInstance

public void insertOrUpdateInstance(String domain,
                                   String app,
                                   String cluster,
                                   String host,
                                   String ip,
                                   Date startTime,
                                   long pid)
                            throws SQLException

Specified by:

insertOrUpdateInstance in interface MonitorDao

Throws:

SQLException

findInst

public MonitorInstance findInst(String domain,
                                String app,
                                String cluster,
                                String host)
                         throws SQLException

Throws:

SQLException

listInst

public List<MonitorInstance> listInst(String domain,
                                      String app,
                                      String cluster)
                               throws SQLException

Throws:

SQLException