Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

bug fixed

Browse Source
This commit is contained in:
wenshao
2013-08-14 20:19:07 +08:00
parent 7a7f77182b
commit 7f255fa494
3 changed files with 33 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/com/alibaba/druid/bvt/support/monitor/MonitorDaoJdbcImplTest.java
+30 -6
View File
@@ -1,31 +1,55 @@
package com.alibaba.druid.bvt.support.monitor;
import java.util.Collections;
import java.util.Date;
import java.util.List;
import junit.framework.TestCase;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.sql.SQLUtils;
import com.alibaba.druid.stat.JdbcSqlStatValue;
import com.alibaba.druid.support.monitor.MonitorClient;
import com.alibaba.druid.support.monitor.dao.MonitorDaoJdbcImpl;
import com.alibaba.druid.support.monitor.dao.MonitorDaoJdbcImpl.BeanInfo;
import com.alibaba.druid.support.monitor.dao.MonitorDaoJdbcImpl.FieldInfo;
import com.alibaba.druid.util.JdbcConstants;
import com.alibaba.druid.util.JdbcUtils;
public class MonitorDaoJdbcImplTest extends TestCase {
private DruidDataSource dataSource;
@Override
protected void setUp() throws Exception {
dataSource = new DruidDataSource();
dataSource.setUrl("jdbc:h2:mem:test");
dataSource.setInitialSize(2);
dataSource.setMinIdle(2);
dataSource.setFilters("stat,log4j");
dataSource.init();
}
@Override
protected void tearDown() throws Exception {
JdbcUtils.close(dataSource);
}
public void testBuildSql() throws Exception {
MonitorDaoJdbcImpl dao = new MonitorDaoJdbcImpl();
dao.setDataSource(dataSource);
{
String sql = dao.buildInsertSql(new BeanInfo(JdbcSqlStatValue.class));
System.out.println(SQLUtils.format(sql, JdbcConstants.MYSQL));
}
MonitorClient client = new MonitorClient();
client.setDao(dao);
{
String sql = buildCreateSql(dao, new BeanInfo(JdbcSqlStatValue.class));
System.out.println(SQLUtils.format(sql, JdbcConstants.MYSQL));
JdbcUtils.execute(dataSource, sql, Collections.emptyList());
}
client.collectSql();
}
public String buildCreateSql(MonitorDaoJdbcImpl dao, BeanInfo beanInfo) {
@@ -34,7 +58,7 @@ public class MonitorDaoJdbcImplTest extends TestCase {
buf.append("CREATE TABLE ") //
.append(dao.getTableName(beanInfo));
buf.append("( id bigint(20) NOT NULL");
buf.append("( id bigint(20) NOT NULL AUTO_INCREMENT");
buf.append(", domain varchar(45)");
buf.append(", app varchar(45)");
buf.append(", cluster varchar(45)");