Added:
logging/log4j/log4j2/trunk/core/src/test/java/org/apache/logging/log4j/core/appender/db/nosql/NoSQLDatabaseManagerTest.java
URL:
http://svn.apache.org/viewvc/logging/log4j/log4j2/trunk/core/src/test/java/org/apache/logging/log4j/core/appender/db/nosql/NoSQLDatabaseManagerTest.java?rev=1481028&view=auto
==============================================================================
---
logging/log4j/log4j2/trunk/core/src/test/java/org/apache/logging/log4j/core/appender/db/nosql/NoSQLDatabaseManagerTest.java
(added)
+++
logging/log4j/log4j2/trunk/core/src/test/java/org/apache/logging/log4j/core/appender/db/nosql/NoSQLDatabaseManagerTest.java
Fri May 10 14:33:42 2013
@@ -0,0 +1,551 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache license, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the license for the specific language governing permissions and
+ * limitations under the license.
+ */
+package org.apache.logging.log4j.core.appender.db.nosql;
+
+import static org.easymock.EasyMock.anyInt;
+import static org.easymock.EasyMock.capture;
+import static org.easymock.EasyMock.createStrictMock;
+import static org.easymock.EasyMock.expect;
+import static org.easymock.EasyMock.expectLastCall;
+import static org.easymock.EasyMock.getCurrentArguments;
+import static org.easymock.EasyMock.replay;
+import static org.easymock.EasyMock.reset;
+import static org.easymock.EasyMock.verify;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
+
+import java.io.IOException;
+import java.sql.SQLException;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.logging.log4j.Level;
+import org.apache.logging.log4j.MarkerManager;
+import org.apache.logging.log4j.ThreadContext;
+import org.apache.logging.log4j.core.LogEvent;
+import org.apache.logging.log4j.core.appender.db.nosql.couch.CouchDBObject;
+import org.apache.logging.log4j.message.Message;
+import org.easymock.Capture;
+import org.easymock.IAnswer;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+public class NoSQLDatabaseManagerTest {
+ NoSQLConnection<Map<String, Object>, CouchDBObject> connection;
+ NoSQLProvider<NoSQLConnection<Map<String, Object>, CouchDBObject>>
provider;
+
+ @Before
+ @SuppressWarnings("unchecked")
+ public void setUp() {
+ this.provider = createStrictMock(NoSQLProvider.class);
+ this.connection = createStrictMock(NoSQLConnection.class);
+ }
+
+ @After
+ public void tearDown() {
+ verify(this.provider, this.connection);
+ }
+
+ @Test
+ public void testConnection() {
+ replay(this.provider, this.connection);
+
+ final NoSQLDatabaseManager<?> manager =
NoSQLDatabaseManager.getNoSQLDatabaseManager("name", 0, this.provider);
+
+ assertNotNull("The manager should not be null.", manager);
+
+ try {
+ verify(this.provider, this.connection);
+ reset(this.provider, this.connection);
+ expect(this.provider.getConnection()).andReturn(this.connection);
+ replay(this.provider, this.connection);
+
+ manager.connectInternal();
+
+ verify(this.provider, this.connection);
+ reset(this.provider, this.connection);
+ expect(this.connection.isClosed()).andReturn(false);
+ this.connection.close();
+ expectLastCall();
+ replay(this.provider, this.connection);
+
+ manager.disconnectInternal();
+ } finally {
+ try {
+ manager.release();
+ } catch (final Throwable ignore) { /* */
+ }
+ }
+ }
+
+ @Test
+ public void testWriteInternal01() {
+ expect(this.provider.getConnection()).andReturn(this.connection);
+ replay(this.provider, this.connection);
+
+ final NoSQLDatabaseManager<?> manager =
NoSQLDatabaseManager.getNoSQLDatabaseManager("name", 0, this.provider);
+
+ try {
+ manager.connect();
+
+ verify(this.provider, this.connection);
+ reset(this.provider, this.connection);
+
+ final Capture<NoSQLObject<Map<String, Object>>> capture = new
Capture<NoSQLObject<Map<String, Object>>>();
+
+ final LogEvent event = createStrictMock(LogEvent.class);
+ final Message message = createStrictMock(Message.class);
+
+ expect(this.connection.isClosed()).andReturn(false);
+ expect(this.connection.createObject()).andAnswer(new
IAnswer<CouchDBObject>() {
+ @Override
+ public CouchDBObject answer() throws Throwable {
+ return new CouchDBObject();
+ }
+ }).atLeastOnce();
+ expect(event.getLevel()).andReturn(Level.WARN);
+
expect(event.getLoggerName()).andReturn("com.foo.NoSQLDbTest.testWriteInternal01");
+ expect(event.getMessage()).andReturn(message).times(2);
+ expect(message.getFormattedMessage()).andReturn("My formatted
message 01.");
+ expect(event.getSource()).andReturn(new
StackTraceElement("com.foo.Bar", "testMethod01", "Bar.java", 15));
+ expect(event.getMarker()).andReturn(null);
+ expect(event.getThreadName()).andReturn("MyThread-A");
+ expect(event.getMillis()).andReturn(1234567890123L).times(2);
+ expect(event.getThrown()).andReturn(null);
+ expect(event.getContextMap()).andReturn(null);
+ expect(event.getContextStack()).andReturn(null);
+ this.connection.insertObject(capture(capture));
+ expectLastCall();
+ replay(this.provider, this.connection, event, message);
+
+ manager.writeInternal(event);
+
+ final NoSQLObject<Map<String, Object>> inserted =
capture.getValue();
+ assertNotNull("The inserted value should not be null.", inserted);
+ final Map<String, Object> object = inserted.unwrap();
+ assertNotNull("The unwrapped object should not be null.", object);
+
+ assertEquals("The level is not correct.", Level.WARN,
object.get("level"));
+ assertEquals("The logger is not correct.",
"com.foo.NoSQLDbTest.testWriteInternal01",
+ object.get("loggerName"));
+ assertEquals("The message is not correct.", "My formatted message
01.", object.get("message"));
+ assertEquals("The thread is not correct.", "MyThread-A",
object.get("threadName"));
+ assertEquals("The millis is not correct.", 1234567890123L,
object.get("millis"));
+ assertEquals("The date is not correct.", 1234567890123L, ((Date)
object.get("date")).getTime());
+
+ assertTrue("The source should be a map.", object.get("source")
instanceof Map);
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> source = (Map<String, Object>)
object.get("source");
+ assertEquals("The class is not correct.", "com.foo.Bar",
source.get("className"));
+ assertEquals("The method is not correct.", "testMethod01",
source.get("methodName"));
+ assertEquals("The file name is not correct.", "Bar.java",
source.get("fileName"));
+ assertEquals("The line number is not correct.", 15,
source.get("lineNumber"));
+
+ assertNull("The marker should be null.", object.get("marker"));
+
+ assertNull("The thrown should be null.", object.get("thrown"));
+
+ assertNull("The context map should be null.",
object.get("contextMap"));
+
+ assertNull("The context stack should be null.",
object.get("contextStack"));
+
+ verify(this.provider, this.connection, event, message);
+ reset(this.provider, this.connection);
+ expect(this.connection.isClosed()).andReturn(false);
+ this.connection.close();
+ expectLastCall();
+ replay(this.provider, this.connection);
+ } finally {
+ try {
+ manager.release();
+ } catch (final Throwable ignore) { /* */
+ }
+ }
+ }
+
+ @Test
+ public void testWriteInternal02() {
+ expect(this.provider.getConnection()).andReturn(this.connection);
+ replay(this.provider, this.connection);
+
+ final NoSQLDatabaseManager<?> manager =
NoSQLDatabaseManager.getNoSQLDatabaseManager("name", 0, this.provider);
+
+ try {
+ manager.connect();
+
+ verify(this.provider, this.connection);
+ reset(this.provider, this.connection);
+
+ final Capture<NoSQLObject<Map<String, Object>>> capture = new
Capture<NoSQLObject<Map<String, Object>>>();
+
+ final RuntimeException exception = new RuntimeException("This is
something cool!");
+ final Map<String, String> context = new HashMap<String, String>();
+ context.put("hello", "world");
+ context.put("user", "pass");
+
+ final LogEvent event = createStrictMock(LogEvent.class);
+ final Message message = createStrictMock(Message.class);
+ ThreadContext.push("message1");
+ ThreadContext.push("stack2");
+ final ThreadContext.ContextStack stack =
ThreadContext.getImmutableStack();
+ ThreadContext.clearStack();
+
+ expect(this.connection.isClosed()).andReturn(false);
+ expect(this.connection.createObject()).andAnswer(new
IAnswer<CouchDBObject>() {
+ @Override
+ public CouchDBObject answer() throws Throwable {
+ return new CouchDBObject();
+ }
+ }).atLeastOnce();
+ expect(this.connection.createList(anyInt())).andAnswer(new
IAnswer<CouchDBObject[]>() {
+ @Override
+ public CouchDBObject[] answer() throws Throwable {
+ return new CouchDBObject[(Integer)
getCurrentArguments()[0]];
+ }
+ });
+ expect(this.connection.createObject()).andAnswer(new
IAnswer<CouchDBObject>() {
+ @Override
+ public CouchDBObject answer() throws Throwable {
+ return new CouchDBObject();
+ }
+ }).atLeastOnce();
+ expect(event.getLevel()).andReturn(Level.DEBUG);
+
expect(event.getLoggerName()).andReturn("com.foo.NoSQLDbTest.testWriteInternal02");
+ expect(event.getMessage()).andReturn(message).times(2);
+ expect(message.getFormattedMessage()).andReturn("Another cool
message 02.");
+ expect(event.getSource()).andReturn(new
StackTraceElement("com.bar.Foo", "anotherMethod03", "Foo.java", 9));
+
expect(event.getMarker()).andReturn(MarkerManager.getMarker("LoneMarker"));
+ expect(event.getThreadName()).andReturn("AnotherThread-B");
+ expect(event.getMillis()).andReturn(987654321564L).times(2);
+ expect(event.getThrown()).andReturn(exception);
+ expect(event.getContextMap()).andReturn(context);
+ expect(event.getContextStack()).andReturn(stack);
+ this.connection.insertObject(capture(capture));
+ expectLastCall();
+ replay(this.provider, this.connection, event, message);
+
+ manager.writeInternal(event);
+
+ final NoSQLObject<Map<String, Object>> inserted =
capture.getValue();
+ assertNotNull("The inserted value should not be null.", inserted);
+ final Map<String, Object> object = inserted.unwrap();
+ assertNotNull("The unwrapped object should not be null.", object);
+
+ assertEquals("The level is not correct.", Level.DEBUG,
object.get("level"));
+ assertEquals("The logger is not correct.",
"com.foo.NoSQLDbTest.testWriteInternal02",
+ object.get("loggerName"));
+ assertEquals("The message is not correct.", "Another cool message
02.", object.get("message"));
+ assertEquals("The thread is not correct.", "AnotherThread-B",
object.get("threadName"));
+ assertEquals("The millis is not correct.", 987654321564L,
object.get("millis"));
+ assertEquals("The date is not correct.", 987654321564L, ((Date)
object.get("date")).getTime());
+
+ assertTrue("The source should be a map.", object.get("source")
instanceof Map);
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> source = (Map<String, Object>)
object.get("source");
+ assertEquals("The class is not correct.", "com.bar.Foo",
source.get("className"));
+ assertEquals("The method is not correct.", "anotherMethod03",
source.get("methodName"));
+ assertEquals("The file name is not correct.", "Foo.java",
source.get("fileName"));
+ assertEquals("The line number is not correct.", 9,
source.get("lineNumber"));
+
+ assertTrue("The marker should be a map.", object.get("marker")
instanceof Map);
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> marker = (Map<String, Object>)
object.get("marker");
+ assertEquals("The marker name is not correct.", "LoneMarker",
marker.get("name"));
+ assertNull("The marker parent should be null.",
marker.get("parent"));
+
+ assertTrue("The thrown should be a map.", object.get("thrown")
instanceof Map);
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> thrown = (Map<String, Object>)
object.get("thrown");
+ assertEquals("The thrown type is not correct.",
"java.lang.RuntimeException", thrown.get("type"));
+ assertEquals("The thrown message is not correct.", "This is
something cool!", thrown.get("message"));
+ assertTrue("The thrown stack trace should be a list.",
thrown.get("stackTrace") instanceof List);
+ @SuppressWarnings("unchecked")
+ final List<Map<String, Object>> stackTrace = (List<Map<String,
Object>>) thrown.get("stackTrace");
+ assertEquals("The thrown stack trace length is not correct.",
exception.getStackTrace().length,
+ stackTrace.size());
+ for (int i = 0; i < exception.getStackTrace().length; i++) {
+ final StackTraceElement e1 = exception.getStackTrace()[i];
+ final Map<String, Object> e2 = stackTrace.get(i);
+
+ assertEquals("Element class name [" + i + "] is not correct.",
e1.getClassName(), e2.get("className"));
+ assertEquals("Element method name [" + i + "] is not
correct.", e1.getMethodName(),
+ e2.get("methodName"));
+ assertEquals("Element file name [" + i + "] is not correct.",
e1.getFileName(), e2.get("fileName"));
+ assertEquals("Element line number [" + i + "] is not
correct.", e1.getLineNumber(),
+ e2.get("lineNumber"));
+ }
+ assertNull("The thrown should have no cause.",
thrown.get("cause"));
+
+ assertTrue("The context map should be a map.",
object.get("contextMap") instanceof Map);
+ assertEquals("The context map is not correct.", context,
object.get("contextMap"));
+
+ assertTrue("The context stack should be list.",
object.get("contextStack") instanceof List);
+ assertEquals("The context stack is not correct.", stack.asList(),
object.get("contextStack"));
+
+ verify(this.provider, this.connection, event, message);
+ reset(this.provider, this.connection);
+ expect(this.connection.isClosed()).andReturn(false);
+ this.connection.close();
+ expectLastCall();
+ replay(this.provider, this.connection);
+ } finally {
+ try {
+ manager.release();
+ } catch (final Throwable ignore) { /* */
+ }
+ }
+ }
+
+ @Test
+ public void testWriteInternal03() {
+ expect(this.provider.getConnection()).andReturn(this.connection);
+ replay(this.provider, this.connection);
+
+ final NoSQLDatabaseManager<?> manager =
NoSQLDatabaseManager.getNoSQLDatabaseManager("name", 0, this.provider);
+
+ try {
+ manager.connect();
+
+ verify(this.provider, this.connection);
+ reset(this.provider, this.connection);
+
+ final Capture<NoSQLObject<Map<String, Object>>> capture = new
Capture<NoSQLObject<Map<String, Object>>>();
+
+ final IOException exception1 = new IOException("This is the
cause.");
+ final SQLException exception2 = new SQLException("This is the
result.", exception1);
+ final Map<String, String> context = new HashMap<String, String>();
+ context.put("hello", "world");
+ context.put("user", "pass");
+
+ final LogEvent event = createStrictMock(LogEvent.class);
+ final Message message = createStrictMock(Message.class);
+ ThreadContext.push("message1");
+ ThreadContext.push("stack2");
+ final ThreadContext.ContextStack stack =
ThreadContext.getImmutableStack();
+ ThreadContext.clearStack();
+
+ expect(this.connection.isClosed()).andReturn(false);
+ expect(this.connection.createObject()).andAnswer(new
IAnswer<CouchDBObject>() {
+ @Override
+ public CouchDBObject answer() throws Throwable {
+ return new CouchDBObject();
+ }
+ }).atLeastOnce();
+ expect(this.connection.createList(anyInt())).andAnswer(new
IAnswer<CouchDBObject[]>() {
+ @Override
+ public CouchDBObject[] answer() throws Throwable {
+ return new CouchDBObject[(Integer)
getCurrentArguments()[0]];
+ }
+ });
+ expect(this.connection.createObject()).andAnswer(new
IAnswer<CouchDBObject>() {
+ @Override
+ public CouchDBObject answer() throws Throwable {
+ return new CouchDBObject();
+ }
+ }).atLeastOnce();
+ expect(this.connection.createList(anyInt())).andAnswer(new
IAnswer<CouchDBObject[]>() {
+ @Override
+ public CouchDBObject[] answer() throws Throwable {
+ return new CouchDBObject[(Integer)
getCurrentArguments()[0]];
+ }
+ });
+ expect(this.connection.createObject()).andAnswer(new
IAnswer<CouchDBObject>() {
+ @Override
+ public CouchDBObject answer() throws Throwable {
+ return new CouchDBObject();
+ }
+ }).atLeastOnce();
+ expect(event.getLevel()).andReturn(Level.DEBUG);
+
expect(event.getLoggerName()).andReturn("com.foo.NoSQLDbTest.testWriteInternal02");
+ expect(event.getMessage()).andReturn(message).times(2);
+ expect(message.getFormattedMessage()).andReturn("Another cool
message 02.");
+ expect(event.getSource()).andReturn(new
StackTraceElement("com.bar.Foo", "anotherMethod03", "Foo.java", 9));
+ expect(event.getMarker()).andReturn(
+ MarkerManager.getMarker("AnotherMarker",
+ MarkerManager.getMarker("Parent1",
MarkerManager.getMarker("Grandparent2"))));
+ expect(event.getThreadName()).andReturn("AnotherThread-B");
+ expect(event.getMillis()).andReturn(987654321564L).times(2);
+ expect(event.getThrown()).andReturn(exception2);
+ expect(event.getContextMap()).andReturn(context);
+ expect(event.getContextStack()).andReturn(stack);
+ this.connection.insertObject(capture(capture));
+ expectLastCall();
+ replay(this.provider, this.connection, event, message);
+
+ manager.writeInternal(event);
+
+ final NoSQLObject<Map<String, Object>> inserted =
capture.getValue();
+ assertNotNull("The inserted value should not be null.", inserted);
+ final Map<String, Object> object = inserted.unwrap();
+ assertNotNull("The unwrapped object should not be null.", object);
+
+ assertEquals("The level is not correct.", Level.DEBUG,
object.get("level"));
+ assertEquals("The logger is not correct.",
"com.foo.NoSQLDbTest.testWriteInternal02",
+ object.get("loggerName"));
+ assertEquals("The message is not correct.", "Another cool message
02.", object.get("message"));
+ assertEquals("The thread is not correct.", "AnotherThread-B",
object.get("threadName"));
+ assertEquals("The millis is not correct.", 987654321564L,
object.get("millis"));
+ assertEquals("The date is not correct.", 987654321564L, ((Date)
object.get("date")).getTime());
+
+ assertTrue("The source should be a map.", object.get("source")
instanceof Map);
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> source = (Map<String, Object>)
object.get("source");
+ assertEquals("The class is not correct.", "com.bar.Foo",
source.get("className"));
+ assertEquals("The method is not correct.", "anotherMethod03",
source.get("methodName"));
+ assertEquals("The file name is not correct.", "Foo.java",
source.get("fileName"));
+ assertEquals("The line number is not correct.", 9,
source.get("lineNumber"));
+
+ assertTrue("The marker should be a map.", object.get("marker")
instanceof Map);
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> marker = (Map<String, Object>)
object.get("marker");
+ assertEquals("The marker name is not correct.", "AnotherMarker",
marker.get("name"));
+ assertTrue("The marker parent should be a map.",
marker.get("parent") instanceof Map);
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> parentMarker = (Map<String, Object>)
marker.get("parent");
+ assertEquals("The marker parent name is not correct.", "Parent1",
parentMarker.get("name"));
+ assertTrue("The marker grandparent should be a map.",
parentMarker.get("parent") instanceof Map);
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> grandparentMarker = (Map<String,
Object>) parentMarker.get("parent");
+ assertEquals("The marker grandparent name is not correct.",
"Grandparent2", grandparentMarker.get("name"));
+ assertNull("The grandparent marker should have no parent.",
grandparentMarker.get("parent"));
+
+ assertTrue("The thrown should be a map.", object.get("thrown")
instanceof Map);
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> thrown = (Map<String, Object>)
object.get("thrown");
+ assertEquals("The thrown type is not correct.",
"java.sql.SQLException", thrown.get("type"));
+ assertEquals("The thrown message is not correct.", "This is the
result.", thrown.get("message"));
+ assertTrue("The thrown stack trace should be a list.",
thrown.get("stackTrace") instanceof List);
+ @SuppressWarnings("unchecked")
+ final List<Map<String, Object>> stackTrace = (List<Map<String,
Object>>) thrown.get("stackTrace");
+ assertEquals("The thrown stack trace length is not correct.",
exception2.getStackTrace().length,
+ stackTrace.size());
+ for (int i = 0; i < exception2.getStackTrace().length; i++) {
+ final StackTraceElement e1 = exception2.getStackTrace()[i];
+ final Map<String, Object> e2 = stackTrace.get(i);
+
+ assertEquals("Element class name [" + i + "] is not correct.",
e1.getClassName(), e2.get("className"));
+ assertEquals("Element method name [" + i + "] is not
correct.", e1.getMethodName(),
+ e2.get("methodName"));
+ assertEquals("Element file name [" + i + "] is not correct.",
e1.getFileName(), e2.get("fileName"));
+ assertEquals("Element line number [" + i + "] is not
correct.", e1.getLineNumber(),
+ e2.get("lineNumber"));
+ }
+ assertTrue("The thrown cause should be a map.",
thrown.get("cause") instanceof Map);
+ @SuppressWarnings("unchecked")
+ final Map<String, Object> cause = (Map<String, Object>)
thrown.get("cause");
+ assertEquals("The cause type is not correct.",
"java.io.IOException", cause.get("type"));
+ assertEquals("The cause message is not correct.", "This is the
cause.", cause.get("message"));
+ assertTrue("The cause stack trace should be a list.",
cause.get("stackTrace") instanceof List);
+ @SuppressWarnings("unchecked")
+ final List<Map<String, Object>> causeStackTrace =
(List<Map<String, Object>>) cause.get("stackTrace");
+ assertEquals("The cause stack trace length is not correct.",
exception1.getStackTrace().length,
+ causeStackTrace.size());
+ for (int i = 0; i < exception1.getStackTrace().length; i++) {
+ final StackTraceElement e1 = exception1.getStackTrace()[i];
+ final Map<String, Object> e2 = causeStackTrace.get(i);
+
+ assertEquals("Element class name [" + i + "] is not correct.",
e1.getClassName(), e2.get("className"));
+ assertEquals("Element method name [" + i + "] is not
correct.", e1.getMethodName(),
+ e2.get("methodName"));
+ assertEquals("Element file name [" + i + "] is not correct.",
e1.getFileName(), e2.get("fileName"));
+ assertEquals("Element line number [" + i + "] is not
correct.", e1.getLineNumber(),
+ e2.get("lineNumber"));
+ }
+ assertNull("The cause should have no cause.", cause.get("cause"));
+
+ assertTrue("The context map should be a map.",
object.get("contextMap") instanceof Map);
+ assertEquals("The context map is not correct.", context,
object.get("contextMap"));
+
+ assertTrue("The context stack should be list.",
object.get("contextStack") instanceof List);
+ assertEquals("The context stack is not correct.", stack.asList(),
object.get("contextStack"));
+
+ verify(this.provider, this.connection, event, message);
+ reset(this.provider, this.connection);
+ expect(this.connection.isClosed()).andReturn(false);
+ this.connection.close();
+ expectLastCall();
+ replay(this.provider, this.connection);
+ } finally {
+ try {
+ manager.release();
+ } catch (final Throwable ignore) { /* */
+ }
+ }
+ }
+
+ @Test
+ public void testWriteInternalNotConnected01() {
+ replay(this.provider, this.connection);
+
+ final NoSQLDatabaseManager<?> manager =
NoSQLDatabaseManager.getNoSQLDatabaseManager("name", 0, this.provider);
+
+ try {
+ verify(this.provider, this.connection);
+ reset(this.provider, this.connection);
+
+ final LogEvent event = createStrictMock(LogEvent.class);
+ replay(this.provider, this.connection, event);
+
+ manager.writeInternal(event);
+
+ verify(event);
+ } finally {
+ try {
+ manager.release();
+ } catch (final Throwable ignore) { /* */
+ }
+ }
+ }
+
+ @Test
+ public void testWriteInternalNotConnected02() {
+ expect(this.provider.getConnection()).andReturn(this.connection);
+ replay(this.provider, this.connection);
+
+ final NoSQLDatabaseManager<?> manager =
NoSQLDatabaseManager.getNoSQLDatabaseManager("name", 0, this.provider);
+
+ try {
+ manager.connect();
+
+ verify(this.provider, this.connection);
+ reset(this.provider, this.connection);
+
+ final LogEvent event = createStrictMock(LogEvent.class);
+ expect(this.connection.isClosed()).andReturn(true);
+ replay(this.provider, this.connection, event);
+
+ manager.writeInternal(event);
+
+ verify(this.provider, this.connection, event);
+ reset(this.provider, this.connection);
+ expect(this.connection.isClosed()).andReturn(false);
+ this.connection.close();
+ expectLastCall();
+ replay(this.provider, this.connection);
+ } finally {
+ try {
+ manager.release();
+ } catch (final Throwable ignore) { /* */
+ }
+ }
+ }
+}
Propchange:
logging/log4j/log4j2/trunk/core/src/test/java/org/apache/logging/log4j/core/appender/db/nosql/NoSQLDatabaseManagerTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
logging/log4j/log4j2/trunk/core/src/test/java/org/apache/logging/log4j/core/appender/db/nosql/NoSQLDatabaseManagerTest.java
------------------------------------------------------------------------------
svn:keywords = Id
Added:
logging/log4j/log4j2/trunk/core/src/test/resources/META-INF/persistence.xml
URL:
http://svn.apache.org/viewvc/logging/log4j/log4j2/trunk/core/src/test/resources/META-INF/persistence.xml?rev=1481028&view=auto
==============================================================================
--- logging/log4j/log4j2/trunk/core/src/test/resources/META-INF/persistence.xml
(added)
+++ logging/log4j/log4j2/trunk/core/src/test/resources/META-INF/persistence.xml
Fri May 10 14:33:42 2013
@@ -0,0 +1,40 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
+-->
+<persistence xmlns="http://java.sun.com/xml/ns/persistence";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://java.sun.com/xml/ns/persistence
+
http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd";
+ version="1.0">
+
+ <persistence-unit name="jpaAppenderTestUnit">
+ <provider>org.hibernate.ejb.HibernatePersistence</provider>
+ <class>org.apache.logging.log4j.core.appender.db.jpa.TestEntity</class>
+ <exclude-unlisted-classes>false</exclude-unlisted-classes>
+ <properties>
+ <property name="hibernate.connection.username" value="sa" />
+ <property name="hibernate.connection.password" value="" />
+ <property name="hibernate.connection.driver_class"
value="org.hsqldb.jdbcDriver" />
+ <property name="hibernate.connection.url"
value="jdbc:hsqldb:mem:Log4j;ifexists=true" />
+ <property name="hibernate.dialect"
value="org.hibernate.dialect.HSQLDialect" />
+ <property name="hibernate.show_sql" value="true" />
+ <property name="hibernate.format_sql" value="true" />
+ </properties>
+ </persistence-unit>
+
+</persistence>
Propchange:
logging/log4j/log4j2/trunk/core/src/test/resources/META-INF/persistence.xml
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
logging/log4j/log4j2/trunk/core/src/test/resources/META-INF/persistence.xml
------------------------------------------------------------------------------
svn:keywords = Id
Added:
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-driver-manager.xml
URL:
http://svn.apache.org/viewvc/logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-driver-manager.xml?rev=1481028&view=auto
==============================================================================
---
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-driver-manager.xml
(added)
+++
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-driver-manager.xml
Fri May 10 14:33:42 2013
@@ -0,0 +1,46 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
+-->
+<configuration status="debug">
+
+ <appenders>
+ <Console name="STDOUT">
+ <PatternLayout pattern="%C{1.} %m %level MDC%X%n"/>
+ </Console>
+ <Jdbc name="databaseAppender" tableName="dmLogEntry">
+ <DriverManager url="jdbc:hsqldb:mem:Log4j;ifexists=true" username="sa"
password="" />
+ <Column name="eventDate" isEventTimestamp="true" />
+ <Column name="literalColumn" literal="'Literal Value Test String'" />
+ <Column name="level" pattern="%level" />
+ <Column name="logger" pattern="%logger" />
+ <Column name="message" pattern="%message" />
+ <Column name="exception" pattern="%ex{full}" />
+ </Jdbc>
+ </appenders>
+
+ <loggers>
+ <logger name="org.apache.logging.log4j.core.appender.db" level="debug">
+ <appender-ref ref="databaseAppender" />
+ </logger>
+
+ <root level="error">
+ <appender-ref ref="STDOUT"/>
+ </root>
+ </loggers>
+
+</configuration>
Propchange:
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-driver-manager.xml
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-driver-manager.xml
------------------------------------------------------------------------------
svn:keywords = Id
Added:
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-factory-method.xml
URL:
http://svn.apache.org/viewvc/logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-factory-method.xml?rev=1481028&view=auto
==============================================================================
---
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-factory-method.xml
(added)
+++
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-factory-method.xml
Fri May 10 14:33:42 2013
@@ -0,0 +1,47 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
+-->
+<configuration status="debug">
+
+ <appenders>
+ <Console name="STDOUT">
+ <PatternLayout pattern="%C{1.} %m %level MDC%X%n"/>
+ </Console>
+ <Jdbc name="databaseAppender" tableName="fmLogEntry">
+ <ConnectionFactory
class="org.apache.logging.log4j.core.appender.db.jdbc.JDBCAppenderTest"
+ method="testFactoryMethodConfigMethod" />
+ <Column name="eventDate" isEventTimestamp="true" />
+ <Column name="literalColumn" literal="'Some Other Literal Value'" />
+ <Column name="level" pattern="%level" />
+ <Column name="logger" pattern="%logger" />
+ <Column name="message" pattern="%message" />
+ <Column name="exception" pattern="%ex{full}" />
+ </Jdbc>
+ </appenders>
+
+ <loggers>
+ <logger name="org.apache.logging.log4j.core.appender.db" level="debug">
+ <appender-ref ref="databaseAppender" />
+ </logger>
+
+ <root level="error">
+ <appender-ref ref="STDOUT"/>
+ </root>
+ </loggers>
+
+</configuration>
Propchange:
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-factory-method.xml
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jdbc/log4j2-factory-method.xml
------------------------------------------------------------------------------
svn:keywords = Id
Added:
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jpa/log4j2-jpa.xml
URL:
http://svn.apache.org/viewvc/logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jpa/log4j2-jpa.xml?rev=1481028&view=auto
==============================================================================
---
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jpa/log4j2-jpa.xml
(added)
+++
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jpa/log4j2-jpa.xml
Fri May 10 14:33:42 2013
@@ -0,0 +1,39 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
+-->
+<configuration status="debug">
+
+ <appenders>
+ <Console name="STDOUT">
+ <PatternLayout pattern="%C{1.} %m %level MDC%X%n"/>
+ </Console>
+ <Jpa name="databaseAppender" persistenceUnitName="jpaAppenderTestUnit"
+
entityClassName="org.apache.logging.log4j.core.appender.db.jpa.TestEntity" />
+ </appenders>
+
+ <loggers>
+ <logger name="org.apache.logging.log4j.core.appender.db" level="debug">
+ <appender-ref ref="databaseAppender" />
+ </logger>
+
+ <root level="error">
+ <appender-ref ref="STDOUT"/>
+ </root>
+ </loggers>
+
+</configuration>
Propchange:
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jpa/log4j2-jpa.xml
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
logging/log4j/log4j2/trunk/core/src/test/resources/org/apache/logging/log4j/core/appender/db/jpa/log4j2-jpa.xml
------------------------------------------------------------------------------
svn:keywords = Id
