-/*
- Bacula® - The Network Backup Solution
-
- Copyright (C) 2009-2011 Free Software Foundation Europe e.V.
-
- The main author of Bacula is Kern Sibbald, with contributions from
- many others, a complete list can be found in the file AUTHORS.
- This program is Free Software; you can redistribute it and/or
- modify it under the terms of version three of the GNU Affero General Public
- License as published by the Free Software Foundation and included
- in the file LICENSE.
-
- This program is distributed in the hope that it will be useful, but
- WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- General Public License for more details.
-
- You should have received a copy of the GNU Affero General Public License
- along with this program; if not, write to the Free Software
- Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
- 02110-1301, USA.
-
- Bacula® is a registered trademark of Kern Sibbald.
-
- The licensor of Bacula is the Free Software Foundation Europe
- (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich,
- Switzerland, email:ftf@fsfeurope.org.
-*/
-#ifndef __BDB_MYSQL_H_
-#define __BDB_MYSQL_H_ 1
-
-class B_DB_MYSQL: public B_DB_PRIV {
-private:
- MYSQL *m_db_handle;
- MYSQL m_instance;
- MYSQL_RES *m_result;
-
-public:
- B_DB_MYSQL(JCR *jcr, const char *db_driver, const char *db_name,
- const char *db_user, const char *db_password,
- const char *db_address, int db_port, const char *db_socket,
- bool mult_db_connections, bool disable_batch_insert);
- ~B_DB_MYSQL();
-
- /* low level operations */
- bool db_open_database(JCR *jcr);
- void db_close_database(JCR *jcr);
- void db_thread_cleanup(void);
- void db_escape_string(JCR *jcr, char *snew, char *old, int len);
- char *db_escape_object(JCR *jcr, char *old, int len);
- void db_unescape_object(JCR *jcr, char *from, int32_t expected_len,
- POOLMEM **dest, int32_t *len);
- void db_start_transaction(JCR *jcr);
- void db_end_transaction(JCR *jcr);
- bool db_sql_query(const char *query, DB_RESULT_HANDLER *result_handler, void *ctx);
- void sql_free_result(void);
- SQL_ROW sql_fetch_row(void);
- bool sql_query(const char *query, int flags=0);
- const char *sql_strerror(void);
- int sql_num_rows(void);
- void sql_data_seek(int row);
- int sql_affected_rows(void);
- uint64_t sql_insert_autokey_record(const char *query, const char *table_name);
- void sql_field_seek(int field);
- SQL_FIELD *sql_fetch_field(void);
- int sql_num_fields(void);
- bool sql_field_is_not_null(int field_type);
- bool sql_field_is_numeric(int field_type);
- bool sql_batch_start(JCR *jcr);
- bool sql_batch_end(JCR *jcr, const char *error);
- bool sql_batch_insert(JCR *jcr, ATTR_DBR *ar);
-};
-
-#endif /* __BDB_MYSQL_H_ */
+/*
+ Bacula(R) - The Network Backup Solution
+
+ Copyright (C) 2000-2016 Kern Sibbald
+
+ The original author of Bacula is Kern Sibbald, with contributions
+ from many others, a complete list can be found in the file AUTHORS.
+
+ You may use this file and others of this release according to the
+ license defined in the LICENSE file, which includes the Affero General
+ Public License, v3.0 ("AGPLv3") and some additional permissions and
+ terms pursuant to its AGPLv3 Section 7.
+
+ This notice must be preserved when any source code is
+ conveyed and/or propagated.
+
+ Bacula(R) is a registered trademark of Kern Sibbald.
+*/
+
+/* MySQL driver specific definitions */
+
+#ifdef BDB_MYSQL_H_
+
+/*
+ * Number of insert statements to batch-up in batch insert
+ * mode. We use multi-row inserts only in the batch mode
+ * on the private database connection.
+ */
+#define MYSQL_CHANGES_PER_BATCH_INSERT 32
+
+class BDB_MYSQL: public BDB {
+private:
+ MYSQL *m_db_handle;
+ MYSQL m_instance;
+ MYSQL_RES *m_result;
+
+public:
+ BDB_MYSQL();
+ ~BDB_MYSQL();
+
+ /* Functions that we override */
+ bool bdb_open_database(JCR *jcr);
+ void bdb_close_database(JCR *jcr);
+ void bdb_thread_cleanup(void);
+ void bdb_escape_string(JCR *jcr, char *snew, char *old, int len);
+ char *bdb_escape_object(JCR *jcr, char *old, int len);
+ void bdb_unescape_object(JCR *jcr, char *from, int32_t expected_len,
+ POOLMEM **dest, int32_t *len);
+ void bdb_start_transaction(JCR *jcr);
+ void bdb_end_transaction(JCR *jcr);
+ bool bdb_sql_query(const char *query, DB_RESULT_HANDLER *result_handler, void *ctx);
+ void sql_free_result(void);
+ SQL_ROW sql_fetch_row(void);
+ bool sql_query(const char *query, int flags=0);
+ const char *sql_strerror(void);
+ int sql_num_rows(void);
+ void sql_data_seek(int row);
+ int sql_affected_rows(void);
+ uint64_t sql_insert_autokey_record(const char *query, const char *table_name);
+ void sql_field_seek(int field);
+ SQL_FIELD *sql_fetch_field(void);
+ int sql_num_fields(void);
+ bool sql_field_is_not_null(int field_type);
+ bool sql_field_is_numeric(int field_type);
+ bool sql_batch_start(JCR *jcr);
+ bool sql_batch_end(JCR *jcr, const char *error);
+ bool sql_batch_insert(JCR *jcr, ATTR_DBR *ar);
+};
+
+#endif /* BDB_MYSQL_H_ */
projects / bacula / bacula / blobdiff