home/pinpoint
2
0
Fork 0
mirror of https://github.com/wahyd4/pinpoint.git synced 2026-08-17 16:56:15 +10:00
Code Issues Packages Projects Releases Wiki Activity

[강운덕] [PROFILER-39] mysql cubrid preparedStatement api 추가로 호출하는도록 test보완

Browse Source 
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@3994 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Woonduk Kang
2014-06-05 09:32:14 +00:00
parent f289937b14
commit e71b38828e
3 changed files with 272 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/com/nhn/pinpoint/profiler/modifier/db/cubrid/CubridConnectionTest.java
+211
View File
@@ -0,0 +1,211 @@
package com.nhn.pinpoint.profiler.modifier.db.cubrid;
import com.mysql.jdbc.JDBC4PreparedStatement;
import com.nhn.pinpoint.bootstrap.config.ProfilerConfig;
import com.nhn.pinpoint.bootstrap.context.DatabaseInfo;
import com.nhn.pinpoint.bootstrap.logging.PLoggerFactory;
import com.nhn.pinpoint.bootstrap.util.MetaObject;
import com.nhn.pinpoint.common.ServiceType;
import com.nhn.pinpoint.profiler.DefaultAgent;
import com.nhn.pinpoint.profiler.logging.Slf4jLoggerBinder;
import com.nhn.pinpoint.profiler.util.MockAgent;
import com.nhn.pinpoint.profiler.util.TestClassLoader;
import cubrid.jdbc.driver.CUBRIDDriver;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.sql.*;
import java.util.Properties;
/**
* @author emeroad
*/
public class CubridConnectionTest {
private final Logger logger = LoggerFactory.getLogger(this.getClass());
private TestClassLoader loader;
@Test
public void executeQueryAndexecuteUpdate() throws SQLException {
CUBRIDDriver driver = new CUBRIDDriver();
Properties properties = new Properties();
properties.setProperty("user", "dba");
properties.setProperty("password", "nhn!@#123");
Connection connect = driver.connect("jdbc:cubrid:10.101.57.233:30102:pinpoint:::", properties);
PreparedStatement preparedStatement = connect.prepareStatement("select 1 from db_root where 1=?");
preparedStatement.setInt(1, 1);
ResultSet resultSet = preparedStatement.executeQuery();
if (resultSet.next()) {
System.out.println("---" + resultSet.getObject(1));
}
}
@Before
public void setUp() throws Exception {
PLoggerFactory.initialize(new Slf4jLoggerBinder());
ProfilerConfig profilerConfig = new ProfilerConfig();
// profiler config를 setter를 열어두는것도 괜찮을듯 하다.
String path = MockAgent.class.getClassLoader().getResource("pinpoint.config").getPath();
profilerConfig.readConfigFile(path);
profilerConfig.setApplicationServerType(ServiceType.TEST_STAND_ALONE);
DefaultAgent agent = new MockAgent("", profilerConfig);
loader = new TestClassLoader(agent);
// agent가 로드한 모든 Modifier를 자동으로 찾도록 변경함.
loader.initialize();
}
private MetaObject<DatabaseInfo> getUrl = new MetaObject<DatabaseInfo>("__getDatabaseInfo");
@Test
public void testModify() throws Exception {
Driver driver = loadClass();
Properties properties = new Properties();
properties.setProperty("user", "dba");
properties.setProperty("password", "nhn!@#123");
Connection connection = driver.connect("jdbc:cubrid:10.101.57.233:30102:pinpoint:::", properties);
logger.info("Connection class name:{}", connection.getClass().getName());
logger.info("Connection class cl:{}", connection.getClass().getClassLoader());
DatabaseInfo url = getUrl.invoke(connection);
Assert.assertNotNull(url);
statement(connection);
preparedStatement(connection);
preparedStatement2(connection);
preparedStatement3(connection);
preparedStatement4(connection);
preparedStatement5(connection);
preparedStatement6(connection);
preparedStatement7(connection);
preparedStatement8(connection);
connection.close();
DatabaseInfo clearUrl = getUrl.invoke(connection);
Assert.assertNull(clearUrl);
}
private Driver loadClass() throws ClassNotFoundException, InstantiationException, IllegalAccessException {
Class<Driver> driverClazz = (Class<Driver>) loader.loadClass("cubrid.jdbc.driver.CUBRIDDriver");
Driver driver = driverClazz.newInstance();
logger.info("Driver class name:{}", driverClazz.getName());
logger.info("Driver class cl:{}", driverClazz.getClassLoader());
Class<?> version = loader.loadClass("com.nhn.pinpoint.common.Version");
Assert.assertSame("check classLoader", this.getClass().getClassLoader(), version.getClassLoader());
logger.debug("common cl:{}", version.getClassLoader());
return driver;
}
private void statement(Connection connection) throws SQLException {
Statement statement = connection.createStatement();
statement.executeQuery("select 1");
statement.close();
}
private void preparedStatement(Connection connection) throws SQLException {
PreparedStatement preparedStatement = connection.prepareStatement("select 1");
logger.info("PreparedStatement className:" + preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
private void preparedStatement2(Connection connection) throws SQLException {
PreparedStatement preparedStatement = connection.prepareStatement("select * from member where id = ?");
preparedStatement.setInt(1, 1);
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
private void preparedStatement3(Connection connection) throws SQLException {
connection.setAutoCommit(false);
PreparedStatement preparedStatement = connection.prepareStatement("select * from member where id = ? or id = ? or id = ?");
preparedStatement.setInt(1, 1);
preparedStatement.setInt(2, 2);
preparedStatement.setString(3, "3");
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
connection.commit();
connection.setAutoCommit(true);
}
private void preparedStatement4(Connection connection) throws SQLException {
// Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS
PreparedStatement preparedStatement = connection.prepareStatement("select 1", Statement.RETURN_GENERATED_KEYS);
logger.info("PreparedStatement className:{}", preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
private void preparedStatement5(Connection connection) throws SQLException {
// Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS
PreparedStatement preparedStatement = connection.prepareStatement("select 1", new String[]{"test"});
logger.info("PreparedStatement className:{}", preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
private void preparedStatement6(Connection connection) throws SQLException {
// Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS
int[] columnIndex = {1,2,3};
PreparedStatement preparedStatement = connection.prepareStatement("select 1", columnIndex);
logger.info("PreparedStatement className:{}", preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
private void preparedStatement7(Connection connection) throws SQLException {
// Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS
PreparedStatement preparedStatement = connection.prepareStatement("select 1", ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
logger.info("PreparedStatement className:{}", preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
private void preparedStatement8(Connection connection) throws SQLException {
// Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS
// ResultSet.HOLD_CURSORS_OVER_COMMIT or ResultSet.CLOSE_CURSORS_AT_COMMIT
PreparedStatement preparedStatement = connection.prepareStatement("select 1", ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
logger.info("PreparedStatement className:{}", preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
}
src/test/java/com/nhn/pinpoint/profiler/modifier/db/mysql/MySQLConnectionImplModifierTest.java
+60 -1
View File
@@ -30,7 +30,7 @@ import java.util.Properties;
*/
public class MySQLConnectionImplModifierTest {
private final Logger logger = LoggerFactory.getLogger(MySQLConnectionImplModifierTest.class.getName());
private final Logger logger = LoggerFactory.getLogger(this.getClass());
private TestClassLoader loader;
@@ -139,6 +139,16 @@ public class MySQLConnectionImplModifierTest {
preparedStatement3(connection);
preparedStatement4(connection);
preparedStatement5(connection);
preparedStatement6(connection);
preparedStatement7(connection);
preparedStatement8(connection);
connection.close();
DatabaseInfo clearUrl = getUrl.invoke(internalConnection);
Assert.assertNull(clearUrl);
@@ -184,6 +194,55 @@ public class MySQLConnectionImplModifierTest {
connection.setAutoCommit(true);
}
private void preparedStatement4(Connection connection) throws SQLException {
// Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS
PreparedStatement preparedStatement = connection.prepareStatement("select 1", Statement.RETURN_GENERATED_KEYS);
logger.info("PreparedStatement className:{}", preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
private void preparedStatement5(Connection connection) throws SQLException {
// Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS
PreparedStatement preparedStatement = connection.prepareStatement("select 1", new String[]{"test"});
logger.info("PreparedStatement className:{}", preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
private void preparedStatement6(Connection connection) throws SQLException {
// Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS
int[] columnIndex = {1,2,3};
PreparedStatement preparedStatement = connection.prepareStatement("select 1", columnIndex);
logger.info("PreparedStatement className:{}", preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
private void preparedStatement7(Connection connection) throws SQLException {
// Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS
PreparedStatement preparedStatement = connection.prepareStatement("select 1", ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
logger.info("PreparedStatement className:{}", preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
private void preparedStatement8(Connection connection) throws SQLException {
// Statement.RETURN_GENERATED_KEYS or Statement.NO_GENERATED_KEYS
// ResultSet.HOLD_CURSORS_OVER_COMMIT or ResultSet.CLOSE_CURSORS_AT_COMMIT
PreparedStatement preparedStatement = connection.prepareStatement("select 1", ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
logger.info("PreparedStatement className:{}", preparedStatement.getClass().getName());
ResultSet resultSet = preparedStatement.executeQuery();
resultSet.close();
preparedStatement.close();
}
@Test
public void test() throws NoSuchMethodException {
// setNClob(int parameterIndex, NClob value)
src/test/java/com/nhn/pinpoint/profiler/modifier/db/mysql/MySQLConnectionImplTest.java
+1 -1
View File
@@ -14,7 +14,7 @@ import org.slf4j.LoggerFactory;
* @author emeroad
*/
public class MySQLConnectionImplTest {
private final Logger logger = LoggerFactory.getLogger(MySQLConnectionImplTest.class.getName());
private final Logger logger = LoggerFactory.getLogger(this.getClass());
private TestClassLoader loader;