37
37
#include <drizzled/error.h>
38
38
#include <drizzled/query_id.h>
39
39
#include <drizzled/tztime.h>
41
#define log_cs &my_charset_utf8_general_ci
40
#include <drizzled/slave.h>
44
43
static const char *HA_ERR(int i)
2963
2962
session->lex->duplicates= handle_dup;
2965
2964
sql_exchange ex((char*)fname, sql_ex.opt_flags & DUMPFILE_FLAG);
2966
String field_term(sql_ex.field_term,sql_ex.field_term_len,log_cs);
2967
String enclosed(sql_ex.enclosed,sql_ex.enclosed_len,log_cs);
2968
String line_term(sql_ex.line_term,sql_ex.line_term_len,log_cs);
2969
String line_start(sql_ex.line_start,sql_ex.line_start_len,log_cs);
2970
String escaped(sql_ex.escaped,sql_ex.escaped_len, log_cs);
2965
String field_term(sql_ex.field_term,sql_ex.field_term_len,&my_charset_utf8_general_ci);
2966
String enclosed(sql_ex.enclosed,sql_ex.enclosed_len,&my_charset_utf8_general_ci);
2967
String line_term(sql_ex.line_term,sql_ex.line_term_len,&my_charset_utf8_general_ci);
2968
String line_start(sql_ex.line_start,sql_ex.line_start_len,&my_charset_utf8_general_ci);
2969
String escaped(sql_ex.escaped,sql_ex.escaped_len, &my_charset_utf8_general_ci);
2971
2970
ex.field_term= &field_term;
2972
2971
ex.enclosed= &enclosed;
2973
2972
ex.line_term= &line_term;
3090
3089
void Rotate_log_event::pack_info(Protocol *protocol)
3092
3091
char buf1[256], buf[22];
3093
String tmp(buf1, sizeof(buf1), log_cs);
3092
String tmp(buf1, sizeof(buf1), &my_charset_utf8_general_ci);
3095
3094
tmp.append(new_log_ident, ident_len);
3096
3095
tmp.append(STRING_WITH_LEN(";pos="));