lsm/mdbtools
1
0
Fork 0
mirror of https://github.com/mdbtools/mdbtools.git synced 2026-01-02 20:42:14 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

output all non-binary fields as unicode strings and binary fields as MongoDB extended JSON binary field

Browse Source 
Now mdb-exportjson output can be successfully imported into MongoDB with
mongoimport even if:

 * columns have unicode names
 * there are fields of binary types (e.g. OLE)
This commit is contained in:
Vladimir Rutsky
2015-02-19 21:02:15 +03:00
parent f894cc708f
commit 3216c8de03
1 changed files with 20 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/util/mdb-exportjson.c
View File

@@ -18,6 +18,8 @@
#include "mdbtools.h" #include "mdbtools.h"
#include "base64.h"
#ifdef DMALLOC #ifdef DMALLOC
#include "dmalloc.h" #include "dmalloc.h"
#endif #endif
@@ -61,7 +63,7 @@ print_quoted_value(FILE *outfile, char* value, int bin_len) {
value += orig_escape_len; value += orig_escape_len;
#endif #endif
} else if ((unsigned char)*value < 0x20) { } else if ((unsigned char)*value < 0x20) {
if (!is_binary || drop_nonascii) { if (drop_nonascii) {
putc(' ', outfile); putc(' ', outfile);
++value; ++value;
} else { } else {
@@ -75,15 +77,30 @@ print_quoted_value(FILE *outfile, char* value, int bin_len) {
fputs(quote_char, outfile); fputs(quote_char, outfile);
} }
static void
print_binary_value(FILE *outfile, char const * value, int bin_len) {
fputs("{\"$binary\": \"", outfile);
size_t const base64_buf_len = (bin_len / 3 + 1) * 4 + 1;
char * base64_buf = g_malloc(base64_buf_len);
if (base64encode(value, bin_len, base64_buf, base64_buf_len) != 0) {
fprintf(stderr, "Error: Base64 serialization failed.\n");
}
fputs(base64_buf, outfile);
g_free(base64_buf);
fputs("\", \"$type\": \"00\"}", outfile);
}
static void static void
print_col(FILE *outfile, char* col_name, gchar *col_val, int col_type, int bin_len) { print_col(FILE *outfile, char* col_name, gchar *col_val, int col_type, int bin_len) {
print_quoted_value(outfile, col_name, -1); print_quoted_value(outfile, col_name, -1);
fputs(separator_char, outfile); fputs(separator_char, outfile);
if (is_quote_type(col_type)) { if (is_quote_type(col_type)) {
if (!is_binary_type(col_type)) { if (is_binary_type(col_type)) {
print_binary_value(outfile, col_val, bin_len);
bin_len = -1; bin_len = -1;
} } else {
print_quoted_value(outfile, col_val, bin_len); print_quoted_value(outfile, col_val, bin_len);
}
} else } else
fputs(col_val, outfile); fputs(col_val, outfile);
} }