1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package org.apache.logging.log4j.core.appender.db.jdbc;
18
19 import java.io.Serializable;
20 import java.sql.PreparedStatement;
21 import java.util.Arrays;
22 import java.util.Objects;
23
24 import org.apache.logging.log4j.core.Appender;
25 import org.apache.logging.log4j.core.Core;
26 import org.apache.logging.log4j.core.Filter;
27 import org.apache.logging.log4j.core.Layout;
28 import org.apache.logging.log4j.core.appender.AbstractAppender;
29 import org.apache.logging.log4j.core.appender.db.AbstractDatabaseAppender;
30 import org.apache.logging.log4j.core.appender.db.ColumnMapping;
31 import org.apache.logging.log4j.core.config.Property;
32 import org.apache.logging.log4j.core.config.plugins.Plugin;
33 import org.apache.logging.log4j.core.config.plugins.PluginBuilderAttribute;
34 import org.apache.logging.log4j.core.config.plugins.PluginBuilderFactory;
35 import org.apache.logging.log4j.core.config.plugins.PluginElement;
36 import org.apache.logging.log4j.core.config.plugins.convert.TypeConverter;
37 import org.apache.logging.log4j.core.config.plugins.validation.constraints.Required;
38 import org.apache.logging.log4j.core.util.Assert;
39 import org.apache.logging.log4j.core.util.Booleans;
40
41
42
43
44
45
46
47
48
49
50
51
52
53 @Plugin(name = "JDBC", category = Core.CATEGORY_NAME, elementType = Appender.ELEMENT_TYPE, printObject = true)
54 public final class JdbcAppender extends AbstractDatabaseAppender<JdbcDatabaseManager> {
55
56 public static class Builder<B extends Builder<B>> extends AbstractDatabaseAppender.Builder<B>
57 implements org.apache.logging.log4j.core.util.Builder<JdbcAppender> {
58
59 @PluginElement("ConnectionSource")
60 @Required(message = "No ConnectionSource provided")
61 private ConnectionSource connectionSource;
62
63 @PluginBuilderAttribute
64 private boolean immediateFail;
65
66 @PluginBuilderAttribute
67 private int bufferSize;
68
69 @PluginBuilderAttribute
70 @Required(message = "No table name provided")
71 private String tableName;
72
73 @PluginElement("ColumnConfigs")
74 private ColumnConfig[] columnConfigs;
75
76 @PluginElement("ColumnMappings")
77 private ColumnMapping[] columnMappings;
78
79 @PluginBuilderAttribute
80 private boolean truncateStrings = true;
81
82
83 @PluginBuilderAttribute
84 private long reconnectIntervalMillis = DEFAULT_RECONNECT_INTERVAL_MILLIS;
85
86 @Override
87 public JdbcAppender build() {
88 if (Assert.isEmpty(columnConfigs) && Assert.isEmpty(columnMappings)) {
89 LOGGER.error("Cannot create JdbcAppender without any columns.");
90 return null;
91 }
92 final String managerName = "JdbcManager{name=" + getName() + ", bufferSize=" + bufferSize + ", tableName="
93 + tableName + ", columnConfigs=" + Arrays.toString(columnConfigs) + ", columnMappings="
94 + Arrays.toString(columnMappings) + '}';
95 final JdbcDatabaseManager manager = JdbcDatabaseManager.getManager(managerName, bufferSize, getLayout(),
96 connectionSource, tableName, columnConfigs, columnMappings, immediateFail, reconnectIntervalMillis,
97 truncateStrings);
98 if (manager == null) {
99 return null;
100 }
101 return new JdbcAppender(getName(), getFilter(), getLayout(), isIgnoreExceptions(), getPropertyArray(),
102 manager);
103 }
104
105 public long getReconnectIntervalMillis() {
106 return reconnectIntervalMillis;
107 }
108
109 public boolean isImmediateFail() {
110 return immediateFail;
111 }
112
113
114
115
116
117
118
119
120
121 public B setBufferSize(final int bufferSize) {
122 this.bufferSize = bufferSize;
123 return asBuilder();
124 }
125
126
127
128
129
130
131
132
133 public B setColumnConfigs(final ColumnConfig... columnConfigs) {
134 this.columnConfigs = columnConfigs;
135 return asBuilder();
136 }
137
138 public B setColumnMappings(final ColumnMapping... columnMappings) {
139 this.columnMappings = columnMappings;
140 return asBuilder();
141 }
142
143
144
145
146
147
148
149
150 public B setConnectionSource(final ConnectionSource connectionSource) {
151 this.connectionSource = connectionSource;
152 return asBuilder();
153 }
154
155 public void setImmediateFail(final boolean immediateFail) {
156 this.immediateFail = immediateFail;
157 }
158
159 public void setReconnectIntervalMillis(final long reconnectIntervalMillis) {
160 this.reconnectIntervalMillis = reconnectIntervalMillis;
161 }
162
163
164
165
166
167
168
169
170 public B setTableName(final String tableName) {
171 this.tableName = tableName;
172 return asBuilder();
173 }
174
175 public B setTruncateStrings(final boolean truncateStrings) {
176 this.truncateStrings = truncateStrings;
177 return asBuilder();
178 }
179
180 }
181
182
183
184
185
186
187
188 @Deprecated
189 public static <B extends Builder<B>> JdbcAppender createAppender(final String name, final String ignore,
190 final Filter filter,
191 final ConnectionSource connectionSource,
192 final String bufferSize, final String tableName,
193 final ColumnConfig[] columnConfigs) {
194 Assert.requireNonEmpty(name, "Name cannot be empty");
195 Objects.requireNonNull(connectionSource, "ConnectionSource cannot be null");
196 Assert.requireNonEmpty(tableName, "Table name cannot be empty");
197 Assert.requireNonEmpty(columnConfigs, "ColumnConfigs cannot be empty");
198
199 final int bufferSizeInt = AbstractAppender.parseInt(bufferSize, 0);
200 final boolean ignoreExceptions = Booleans.parseBoolean(ignore, true);
201
202 return JdbcAppender.<B>newBuilder()
203 .setBufferSize(bufferSizeInt)
204 .setColumnConfigs(columnConfigs)
205 .setConnectionSource(connectionSource)
206 .setTableName(tableName).setName(name).setIgnoreExceptions(ignoreExceptions).setFilter(filter)
207 .build();
208 }
209
210 @PluginBuilderFactory
211 public static <B extends Builder<B>> B newBuilder() {
212 return new Builder<B>().asBuilder();
213 }
214
215 private final String description;
216
217 private JdbcAppender(final String name, final Filter filter, final Layout<? extends Serializable> layout,
218 final boolean ignoreExceptions, final Property[] properties, final JdbcDatabaseManager manager) {
219 super(name, filter, layout, ignoreExceptions, properties, manager);
220 this.description = this.getName() + "{ manager=" + this.getManager() + " }";
221 }
222
223 @Override
224 public String toString() {
225 return this.description;
226 }
227 }