Merge lp:~linuxjedi/mydumper/mydumper-bp-gzip into lp:~mydumper/mydumper/trunk
- mydumper-bp-gzip
- Merge into trunk
Proposed by
Andrew Hutchings
Status: | Merged |
---|---|
Approved by: | Andrew Hutchings |
Approved revision: | 68 |
Merged at revision: | 68 |
Proposed branch: | lp:~linuxjedi/mydumper/mydumper-bp-gzip |
Merge into: | lp:~mydumper/mydumper/trunk |
Diff against target: |
324 lines (+115/-138) 4 files modified
CMakeLists.txt (+3/-2) cmake/modules/FindMySQL.cmake (+101/-136) docs/usage.rst (+4/-0) mydumper.c (+7/-0) |
To merge this branch: | bzr merge lp:~linuxjedi/mydumper/mydumper-bp-gzip |
Related bugs: | |
Related blueprints: |
Add gzip protocol support
(Undefined)
|
Reviewer | Review Type | Date Requested | Status |
---|---|---|---|
MySQL Data Dumper Team | Pending | ||
Review via email: mp+59282@code.launchpad.net |
Commit message
Description of the change
Add protocol compression
Fixups, especially to CMake
To post a comment you must log in.
Preview Diff
[H/L] Next/Prev Comment, [J/K] Next/Prev File, [N/P] Next/Prev Hunk
1 | === modified file 'CMakeLists.txt' | |||
2 | --- CMakeLists.txt 2011-04-26 19:14:47 +0000 | |||
3 | +++ CMakeLists.txt 2011-04-27 19:54:26 +0000 | |||
4 | @@ -12,7 +12,7 @@ | |||
5 | 12 | 12 | ||
6 | 13 | add_subdirectory(docs) | 13 | add_subdirectory(docs) |
7 | 14 | 14 | ||
9 | 15 | set(CMAKE_C_FLAGS "-Wall -Wunused -Wwrite-strings -Wno-strict-aliasing -Wextra -Werror -Wshadow -O3 -g") | 15 | set(CMAKE_C_FLAGS "-Wall -Wunused -Wwrite-strings -Wno-strict-aliasing -Wextra -Werror -Wshadow -O3 -g ${MYSQL_CFLAGS}") |
10 | 16 | 16 | ||
11 | 17 | include_directories(${MYDUMPER_SOURCE_DIR} ${MYSQL_INCLUDE_DIR} ${GLIB2_INCLUDE_DIR} ${PCRE_INCLUDE_DIR} ${ZLIB_INCLUDE_DIRS}) | 17 | include_directories(${MYDUMPER_SOURCE_DIR} ${MYSQL_INCLUDE_DIR} ${GLIB2_INCLUDE_DIR} ${PCRE_INCLUDE_DIR} ${ZLIB_INCLUDE_DIRS}) |
12 | 18 | 18 | ||
13 | @@ -24,7 +24,8 @@ | |||
14 | 24 | CONFIGURE_FILE(${CMAKE_CURRENT_SOURCE_DIR}/config.h.in ${CMAKE_CURRENT_BINARY_DIR}/config.h) | 24 | CONFIGURE_FILE(${CMAKE_CURRENT_SOURCE_DIR}/config.h.in ${CMAKE_CURRENT_BINARY_DIR}/config.h) |
15 | 25 | 25 | ||
16 | 26 | add_executable(mydumper mydumper.c binlog.c) | 26 | add_executable(mydumper mydumper.c binlog.c) |
18 | 27 | target_link_libraries(mydumper ${MYSQL_LIBRARY} ${MYSQL_EXTRA_LIBRARIES} ${GLIB2_LIBRARIES} ${GTHREAD2_LIBRARIES} ${PCRE_PCRE_LIBRARY} ${ZLIB_LIBRARIES}) | 27 | target_link_libraries(mydumper ${MYSQL_LIBRARIES} ${GLIB2_LIBRARIES} ${GTHREAD2_LIBRARIES} ${PCRE_PCRE_LIBRARY} ${ZLIB_LIBRARIES}) |
19 | 28 | |||
20 | 28 | INSTALL(TARGETS mydumper | 29 | INSTALL(TARGETS mydumper |
21 | 29 | RUNTIME DESTINATION bin | 30 | RUNTIME DESTINATION bin |
22 | 30 | ) | 31 | ) |
23 | 31 | 32 | ||
24 | === modified file 'cmake/modules/FindMySQL.cmake' | |||
25 | --- cmake/modules/FindMySQL.cmake 2011-04-21 20:52:39 +0000 | |||
26 | +++ cmake/modules/FindMySQL.cmake 2011-04-27 19:54:26 +0000 | |||
27 | @@ -1,142 +1,107 @@ | |||
32 | 1 | # | 1 | # - Find MySQL |
33 | 2 | # Find the MySQL client includes and library | 2 | # Find the MySQL includes and client library |
30 | 3 | # | ||
31 | 4 | |||
34 | 5 | # This module defines | 3 | # This module defines |
101 | 6 | # MYSQL_INCLUDE_DIR, where to find mysql.h | 4 | # MYSQL_INCLUDE_DIR, where to find mysql.h |
102 | 7 | # MYSQL_LIBRARIES, the libraries to link against to connect to MySQL | 5 | # MYSQL_LIBRARIES, the libraries needed to use MySQL. |
103 | 8 | # MYSQL_FOUND, if false, you cannot build anything that requires MySQL. | 6 | # MYSQL_FOUND, If false, do not try to use MySQL. |
104 | 9 | 7 | # | |
105 | 10 | # also defined, but not for general use are | 8 | # Copyright (c) 2006, Jaroslaw Staniek, <js@iidea.pl> |
106 | 11 | # MYSQL_LIBRARY, where to find the MySQL library. | 9 | # Lot of adustmens by Michal Cihar <michal@cihar.com> |
107 | 12 | 10 | # | |
108 | 13 | set( MYSQL_FOUND 0 ) | 11 | # vim: expandtab sw=4 ts=4 sts=4: |
109 | 14 | 12 | # | |
110 | 15 | if( UNIX ) | 13 | # Redistribution and use is allowed according to the terms of the BSD license. |
111 | 16 | set(MYSQL_CONFIG_PREFER_PATH "$ENV{MYSQL_HOME}/bin" CACHE FILEPATH | 14 | |
112 | 17 | "preferred path to MySQL (mysql_config)" | 15 | if(UNIX) |
113 | 18 | ) | 16 | set(MYSQL_CONFIG_PREFER_PATH "$ENV{MYSQL_HOME}/bin" CACHE FILEPATH |
114 | 19 | 17 | "preferred path to MySQL (mysql_config)") | |
115 | 20 | find_program(MYSQL_CONFIG mysql_config | 18 | find_program(MYSQL_CONFIG mysql_config |
116 | 21 | ${MYSQL_CONFIG_PREFER_PATH} | 19 | ${MYSQL_CONFIG_PREFER_PATH} |
117 | 22 | /usr/local/mysql/bin/ | 20 | /usr/local/mysql/bin/ |
118 | 23 | /usr/local/bin/ | 21 | /usr/local/bin/ |
119 | 24 | /usr/bin/ | 22 | /usr/bin/ |
120 | 25 | ) | 23 | ) |
121 | 26 | 24 | ||
122 | 27 | if( MYSQL_CONFIG ) | 25 | if(MYSQL_CONFIG) |
123 | 28 | message(STATUS "Using mysql-config: ${MYSQL_CONFIG}") | 26 | message(STATUS "Using mysql-config: ${MYSQL_CONFIG}") |
124 | 29 | # set INCLUDE_DIR | 27 | # set CFLAGS |
125 | 30 | exec_program(${MYSQL_CONFIG} | 28 | exec_program(${MYSQL_CONFIG} |
126 | 31 | ARGS --include | 29 | ARGS --cflags |
127 | 32 | OUTPUT_VARIABLE MY_TMP | 30 | OUTPUT_VARIABLE MY_TMP) |
128 | 33 | ) | 31 | |
129 | 34 | 32 | set(MYSQL_CFLAGS ${MY_TMP} CACHE STRING INTERNAL) | |
130 | 35 | string(REGEX REPLACE "-I([^ ]*)( .*)?" "\\1" MY_TMP "${MY_TMP}") | 33 | |
131 | 36 | set(MYSQL_ADD_INCLUDE_PATH ${MY_TMP} CACHE FILEPATH INTERNAL) | 34 | # set INCLUDE_DIR |
132 | 37 | #message("[DEBUG] MYSQL ADD_INCLUDE_PATH : ${MYSQL_ADD_INCLUDE_PATH}") | 35 | exec_program(${MYSQL_CONFIG} |
133 | 38 | # set LIBRARY_DIR | 36 | ARGS --include |
134 | 39 | exec_program(${MYSQL_CONFIG} | 37 | OUTPUT_VARIABLE MY_TMP) |
135 | 40 | ARGS --libs_r | 38 | |
136 | 41 | OUTPUT_VARIABLE MY_TMP | 39 | string(REGEX REPLACE "-I([^ ]*)( .*)?" "\\1" MY_TMP "${MY_TMP}") |
137 | 42 | ) | 40 | |
138 | 43 | set(MYSQL_ADD_LIBRARIES "") | 41 | set(MYSQL_ADD_INCLUDE_DIR ${MY_TMP} CACHE FILEPATH INTERNAL) |
139 | 44 | string(REGEX MATCHALL "-l[^ ]*" MYSQL_LIB_LIST "${MY_TMP}") | 42 | |
140 | 45 | foreach(LIB ${MYSQL_LIB_LIST}) | 43 | # set LIBRARY_DIR |
141 | 46 | string(REGEX REPLACE "[ ]*-l([^ ]*)" "\\1" LIB "${LIB}") | 44 | exec_program(${MYSQL_CONFIG} |
142 | 47 | list(APPEND MYSQL_ADD_LIBRARIES "${LIB}") | 45 | ARGS --libs_r |
143 | 48 | #message("[DEBUG] MYSQL ADD_LIBRARIES : ${MYSQL_ADD_LIBRARIES}") | 46 | OUTPUT_VARIABLE MY_TMP) |
144 | 49 | endforeach(LIB ${MYSQL_LIB_LIST}) | 47 | |
145 | 50 | 48 | set(MYSQL_ADD_LIBRARIES "") | |
146 | 51 | set(MYSQL_ADD_LIBRARIES_PATH "") | 49 | |
147 | 52 | string(REGEX MATCHALL "-L[^ ]*" MYSQL_LIBDIR_LIST "${MY_TMP}") | 50 | string(REGEX MATCHALL "-l[^ ]*" MYSQL_LIB_LIST "${MY_TMP}") |
148 | 53 | foreach(LIB ${MYSQL_LIBDIR_LIST}) | 51 | foreach(LIB ${MYSQL_LIB_LIST}) |
149 | 54 | string(REGEX REPLACE "[ ]*-L([^ ]*)" "\\1" LIB "${LIB}") | 52 | string(REGEX REPLACE "[ ]*-l([^ ]*)" "\\1" LIB "${LIB}") |
150 | 55 | list(APPEND MYSQL_ADD_LIBRARIES_PATH "${LIB}") | 53 | list(APPEND MYSQL_ADD_LIBRARIES "${LIB}") |
151 | 56 | #message("[DEBUG] MYSQL ADD_LIBRARIES_PATH : ${MYSQL_ADD_LIBRARIES_PATH}") | 54 | endforeach(LIB ${MYSQL_LIBS}) |
152 | 57 | endforeach(LIB ${MYSQL_LIBS}) | 55 | |
153 | 58 | 56 | set(MYSQL_ADD_LIBRARY_PATH "") | |
154 | 59 | else( MYSQL_CONFIG ) | 57 | |
155 | 60 | set(MYSQL_ADD_LIBRARIES "") | 58 | string(REGEX MATCHALL "-L[^ ]*" MYSQL_LIBDIR_LIST "${MY_TMP}") |
156 | 61 | list(APPEND MYSQL_ADD_LIBRARIES "mysqlclient_r") | 59 | foreach(LIB ${MYSQL_LIBDIR_LIST}) |
157 | 62 | endif( MYSQL_CONFIG ) | 60 | string(REGEX REPLACE "[ ]*-L([^ ]*)" "\\1" LIB "${LIB}") |
158 | 63 | endif( UNIX ) | 61 | list(APPEND MYSQL_ADD_LIBRARY_PATH "${LIB}") |
159 | 64 | 62 | endforeach(LIB ${MYSQL_LIBS}) | |
160 | 65 | find_path(MYSQL_INCLUDE_DIR | 63 | |
161 | 66 | NAMES | 64 | else(MYSQL_CONFIG) |
162 | 67 | mysql.h | 65 | set(MYSQL_ADD_LIBRARIES "") |
163 | 68 | PATHS | 66 | list(APPEND MYSQL_ADD_LIBRARIES "mysqlclient") |
164 | 69 | ${MYSQL_ADD_INCLUDE_PATH} | 67 | endif(MYSQL_CONFIG) |
165 | 70 | /usr/include | 68 | else(UNIX) |
166 | 71 | /usr/include/mysql | 69 | set(MYSQL_ADD_INCLUDE_DIR "c:/msys/local/include" CACHE FILEPATH INTERNAL) |
167 | 70 | set(MYSQL_ADD_LIBRARY_PATH "c:/msys/local/lib" CACHE FILEPATH INTERNAL) | ||
168 | 71 | ENDIF(UNIX) | ||
169 | 72 | |||
170 | 73 | find_path(MYSQL_INCLUDE_DIR mysql.h | ||
171 | 72 | /usr/local/include | 74 | /usr/local/include |
173 | 73 | /usr/local/include/mysql | 75 | /usr/local/include/mysql |
174 | 74 | /usr/local/mysql/include | 76 | /usr/local/mysql/include |
186 | 75 | "C:/Program Files/MySQL/include" | 77 | /usr/local/mysql/include/mysql |
187 | 76 | "C:/Program Files/MySQL/MySQL Server 5.0/include" | 78 | /usr/include |
188 | 77 | "C:/Program Files/MySQL/MySQL Server 5.1/include" | 79 | /usr/include/mysql |
189 | 78 | "C:/MySQL/include" | 80 | ${MYSQL_ADD_INCLUDE_DIR} |
179 | 79 | "[HKEY_LOCAL_MACHINE\\SOFTWARE\\MySQL AB\\MySQL Server 5.0;Location]/include" | ||
180 | 80 | "[HKEY_LOCAL_MACHINE\\SOFTWARE\\MySQL AB\\MySQL Server 5.1;Location]/include" | ||
181 | 81 | "[HKEY_LOCAL_MACHINE\\SOFTWARE\\Wow6432Node\\MySQL AB\\MySQL Server 5.0;Location]/include" | ||
182 | 82 | "[HKEY_LOCAL_MACHINE\\SOFTWARE\\Wow6432Node\\MySQL AB\\MySQL Server 5.1;Location]/include" | ||
183 | 83 | "c:/msys/local/include" | ||
184 | 84 | DOC | ||
185 | 85 | "Specify the directory containing mysql.h." | ||
190 | 86 | ) | 81 | ) |
191 | 87 | 82 | ||
193 | 88 | if( UNIX ) | 83 | set(TMP_MYSQL_LIBRARIES "") |
194 | 84 | |||
195 | 89 | foreach(LIB ${MYSQL_ADD_LIBRARIES}) | 85 | foreach(LIB ${MYSQL_ADD_LIBRARIES}) |
249 | 90 | find_library( MYSQL_LIBRARY | 86 | find_library("MYSQL_LIBRARIES_${LIB}" NAMES ${LIB} |
250 | 91 | NAMES | 87 | PATHS |
251 | 92 | mysql libmysql ${LIB} | 88 | ${MYSQL_ADD_LIBRARY_PATH} |
252 | 93 | PATHS | 89 | /usr/lib/mysql |
253 | 94 | ${MYSQL_ADD_LIBRARIES_PATH} | 90 | /usr/local/lib |
254 | 95 | /usr/lib | 91 | /usr/local/lib/mysql |
255 | 96 | /usr/lib/mysql | 92 | /usr/local/mysql/lib |
256 | 97 | /usr/local/lib | 93 | ) |
257 | 98 | /usr/local/lib/mysql | 94 | list(APPEND TMP_MYSQL_LIBRARIES "${MYSQL_LIBRARIES_${LIB}}") |
258 | 99 | /usr/local/mysql/lib | 95 | endforeach(LIB ${MYSQL_ADD_LIBRARIES}) |
259 | 100 | "C:/Program Files/MySQL/lib" | 96 | |
260 | 101 | "C:/Program Files/MySQL/MySQL Server 5.0/lib/opt" | 97 | set(MYSQL_LIBRARIES ${TMP_MYSQL_LIBRARIES} CACHE FILEPATH INTERNAL) |
261 | 102 | "C:/Program Files/MySQL/MySQL Server 5.1/lib/opt" | 98 | |
262 | 103 | "C:/MySQL/lib/debug" | 99 | if(MYSQL_INCLUDE_DIR AND MYSQL_LIBRARIES) |
263 | 104 | "[HKEY_LOCAL_MACHINE\\SOFTWARE\\MySQL AB\\MySQL Server 5.0;Location]/lib/opt" | 100 | set(MYSQL_FOUND TRUE CACHE INTERNAL "MySQL found") |
264 | 105 | "[HKEY_LOCAL_MACHINE\\SOFTWARE\\MySQL AB\\MySQL Server 5.1;Location]/lib/opt" | 101 | message(STATUS "Found MySQL: ${MYSQL_INCLUDE_DIR}, ${MYSQL_LIBRARIES}") |
265 | 106 | "[HKEY_LOCAL_MACHINE\\SOFTWARE\\Wow6432Node\\MySQL AB\\MySQL Server 5.0;Location]/lib/opt" | 102 | else(MYSQL_INCLUDE_DIR AND MYSQL_LIBRARIES) |
266 | 107 | "[HKEY_LOCAL_MACHINE\\SOFTWARE\\Wow6432Node\\MySQL AB\\MySQL Server 5.1;Location]/lib/opt" | 103 | set(MYSQL_FOUND FALSE CACHE INTERNAL "MySQL found") |
267 | 108 | "c:/msys/local/include" | 104 | message(STATUS "MySQL not found.") |
268 | 109 | DOC "Specify the location of the mysql library here." | 105 | endif(MYSQL_INCLUDE_DIR AND MYSQL_LIBRARIES) |
269 | 110 | ) | 106 | |
270 | 111 | endforeach(LIB ${MYSQL_ADD_LIBRARY}) | 107 | mark_as_advanced(MYSQL_INCLUDE_DIR MYSQL_LIBRARIES MYSQL_CFLAGS) |
218 | 112 | endif( UNIX ) | ||
219 | 113 | |||
220 | 114 | # On Windows you typically don't need to include any extra libraries | ||
221 | 115 | # to build MYSQL stuff. | ||
222 | 116 | |||
223 | 117 | if( NOT WIN32 ) | ||
224 | 118 | find_library( MYSQL_EXTRA_LIBRARIES | ||
225 | 119 | NAMES | ||
226 | 120 | z zlib | ||
227 | 121 | PATHS | ||
228 | 122 | /usr/lib | ||
229 | 123 | /usr/local/lib | ||
230 | 124 | DOC | ||
231 | 125 | "if more libraries are necessary to link in a MySQL client (typically zlib), specify them here." | ||
232 | 126 | ) | ||
233 | 127 | else( NOT WIN32 ) | ||
234 | 128 | set( MYSQL_EXTRA_LIBRARIES "" ) | ||
235 | 129 | endif( NOT WIN32 ) | ||
236 | 130 | |||
237 | 131 | if( MYSQL_LIBRARY ) | ||
238 | 132 | if( MYSQL_INCLUDE_DIR ) | ||
239 | 133 | set( MYSQL_FOUND 1 ) | ||
240 | 134 | message(STATUS "Found MySQL library: ${MYSQL_LIBRARY}") | ||
241 | 135 | message(STATUS "Found MySQL headers: ${MYSQL_INCLUDE_DIR}") | ||
242 | 136 | else( MYSQL_INCLUDE_DIR ) | ||
243 | 137 | message(FATAL_ERROR "Could not find MySQL headers! Please install the development-libraries and headers.") | ||
244 | 138 | endif( MYSQL_INCLUDE_DIR ) | ||
245 | 139 | mark_as_advanced( MYSQL_FOUND MYSQL_LIBRARY MYSQL_EXTRA_LIBRARIES MYSQL_INCLUDE_DIR ) | ||
246 | 140 | else( MYSQL_LIBRARY ) | ||
247 | 141 | message(FATAL_ERROR "Could not find the MySQL libraries! Please install the development-libraries and headers.") | ||
248 | 142 | endif( MYSQL_LIBRARY ) | ||
271 | 143 | 108 | ||
272 | === modified file 'docs/usage.rst' | |||
273 | --- docs/usage.rst 2011-04-26 17:46:33 +0000 | |||
274 | +++ docs/usage.rst 2011-04-27 19:54:26 +0000 | |||
275 | @@ -76,6 +76,10 @@ | |||
276 | 76 | 76 | ||
277 | 77 | Compress the output files | 77 | Compress the output files |
278 | 78 | 78 | ||
279 | 79 | .. option:: --compress-input, -C | ||
280 | 80 | |||
281 | 81 | Use client protocol compression for connections to the MySQL server | ||
282 | 82 | |||
283 | 79 | .. option:: --build-empty-files, -e | 83 | .. option:: --build-empty-files, -e |
284 | 80 | 84 | ||
285 | 81 | Create empty dump files if there is no data to dump | 85 | Create empty dump files if there is no data to dump |
286 | 82 | 86 | ||
287 | === modified file 'mydumper.c' | |||
288 | --- mydumper.c 2011-04-27 06:39:15 +0000 | |||
289 | +++ mydumper.c 2011-04-27 19:54:26 +0000 | |||
290 | @@ -61,6 +61,7 @@ | |||
291 | 61 | 61 | ||
292 | 62 | int need_dummy_read=0; | 62 | int need_dummy_read=0; |
293 | 63 | int compress_output=0; | 63 | int compress_output=0; |
294 | 64 | int compress_input=1; | ||
295 | 64 | int killqueries=0; | 65 | int killqueries=0; |
296 | 65 | 66 | ||
297 | 66 | gchar *ignore_engines = NULL; | 67 | gchar *ignore_engines = NULL; |
298 | @@ -88,6 +89,7 @@ | |||
299 | 88 | { "statement-size", 's', 0, G_OPTION_ARG_INT, &statement_size, "Attempted size of INSERT statement in bytes", NULL}, | 89 | { "statement-size", 's', 0, G_OPTION_ARG_INT, &statement_size, "Attempted size of INSERT statement in bytes", NULL}, |
300 | 89 | { "rows", 'r', 0, G_OPTION_ARG_INT, &rows_per_file, "Try to split tables into chunks of this many rows", NULL}, | 90 | { "rows", 'r', 0, G_OPTION_ARG_INT, &rows_per_file, "Try to split tables into chunks of this many rows", NULL}, |
301 | 90 | { "compress", 'c', 0, G_OPTION_ARG_NONE, &compress_output, "Compress output files", NULL}, | 91 | { "compress", 'c', 0, G_OPTION_ARG_NONE, &compress_output, "Compress output files", NULL}, |
302 | 92 | { "compress-input", 'C', 0, G_OPTION_ARG_NONE, &compress_input, "Use compression on the MySQL connection", NULL }, | ||
303 | 91 | { "build-empty-files", 'e', 0, G_OPTION_ARG_NONE, &build_empty_files, "Build dump files even if no data available from table", NULL}, | 93 | { "build-empty-files", 'e', 0, G_OPTION_ARG_NONE, &build_empty_files, "Build dump files even if no data available from table", NULL}, |
304 | 92 | { "regex", 'x', 0, G_OPTION_ARG_STRING, ®exstring, "Regular expression for 'db.table' matching", NULL}, | 94 | { "regex", 'x', 0, G_OPTION_ARG_STRING, ®exstring, "Regular expression for 'db.table' matching", NULL}, |
305 | 93 | { "ignore-engines", 'i', 0, G_OPTION_ARG_STRING, &ignore_engines, "Comma delimited list of storage engines to ignore", NULL }, | 95 | { "ignore-engines", 'i', 0, G_OPTION_ARG_STRING, &ignore_engines, "Comma delimited list of storage engines to ignore", NULL }, |
306 | @@ -197,6 +199,9 @@ | |||
307 | 197 | 199 | ||
308 | 198 | mysql_options(thrconn,MYSQL_READ_DEFAULT_GROUP,"mydumper"); | 200 | mysql_options(thrconn,MYSQL_READ_DEFAULT_GROUP,"mydumper"); |
309 | 199 | 201 | ||
310 | 202 | if (compress_input) | ||
311 | 203 | mysql_options(thrconn,MYSQL_OPT_COMPRESS,NULL); | ||
312 | 204 | |||
313 | 200 | if (!mysql_real_connect(thrconn, hostname, username, password, NULL, port, socket_path, 0)) { | 205 | if (!mysql_real_connect(thrconn, hostname, username, password, NULL, port, socket_path, 0)) { |
314 | 201 | g_critical("Failed to connect to database: %s", mysql_error(thrconn)); | 206 | g_critical("Failed to connect to database: %s", mysql_error(thrconn)); |
315 | 202 | exit(EXIT_FAILURE); | 207 | exit(EXIT_FAILURE); |
316 | @@ -256,6 +261,8 @@ | |||
317 | 256 | thrconn= mysql_init(NULL); | 261 | thrconn= mysql_init(NULL); |
318 | 257 | g_mutex_unlock(init_mutex); | 262 | g_mutex_unlock(init_mutex); |
319 | 258 | } | 263 | } |
320 | 264 | if (compress_input) | ||
321 | 265 | mysql_options(thrconn,MYSQL_OPT_COMPRESS,NULL); | ||
322 | 259 | 266 | ||
323 | 260 | if (!mysql_real_connect(thrconn, hostname, username, password, NULL, port, socket_path, 0)) { | 267 | if (!mysql_real_connect(thrconn, hostname, username, password, NULL, port, socket_path, 0)) { |
324 | 261 | g_critical("Failed to connect to database: %s", mysql_error(thrconn)); | 268 | g_critical("Failed to connect to database: %s", mysql_error(thrconn)); |