mirror of
https://github.com/haiwen/seafile-server.git
synced 2025-04-27 19:15:07 +00:00
b558426da8
* Add ca_path and skip_verify option for mysql * Add comment --------- Co-authored-by: 杨赫然 <heran.yang@seafile.com>
132 lines
3.2 KiB
C
132 lines
3.2 KiB
C
#ifndef SEAF_DB_H
|
|
#define SEAF_DB_H
|
|
|
|
enum {
|
|
SEAF_DB_TYPE_SQLITE,
|
|
SEAF_DB_TYPE_MYSQL,
|
|
SEAF_DB_TYPE_PGSQL,
|
|
};
|
|
|
|
typedef struct SeafDB SeafDB;
|
|
typedef struct SeafDB CcnetDB;
|
|
typedef struct SeafDBRow SeafDBRow;
|
|
typedef struct SeafDBRow CcnetDBRow;
|
|
typedef struct SeafDBTrans SeafDBTrans;
|
|
typedef struct SeafDBTrans CcnetDBTrans;
|
|
|
|
typedef gboolean (*SeafDBRowFunc) (SeafDBRow *, void *);
|
|
typedef gboolean (*CcnetDBRowFunc) (CcnetDBRow *, void *);
|
|
|
|
SeafDB *
|
|
seaf_db_new_mysql (const char *host,
|
|
int port,
|
|
const char *user,
|
|
const char *passwd,
|
|
const char *db,
|
|
const char *unix_socket,
|
|
gboolean use_ssl,
|
|
gboolean skip_verify,
|
|
const char *ca_path,
|
|
const char *charset,
|
|
int max_connections);
|
|
|
|
#if 0
|
|
SeafDB *
|
|
seaf_db_new_pgsql (const char *host,
|
|
unsigned int port,
|
|
const char *user,
|
|
const char *passwd,
|
|
const char *db_name,
|
|
const char *unix_socket,
|
|
int max_connections);
|
|
#endif
|
|
|
|
SeafDB *
|
|
seaf_db_new_sqlite (const char *db_path, int max_connections);
|
|
|
|
int
|
|
seaf_db_type (SeafDB *db);
|
|
|
|
int
|
|
seaf_db_query (SeafDB *db, const char *sql);
|
|
|
|
gboolean
|
|
seaf_db_check_for_existence (SeafDB *db, const char *sql, gboolean *db_err);
|
|
|
|
int
|
|
seaf_db_foreach_selected_row (SeafDB *db, const char *sql,
|
|
SeafDBRowFunc callback, void *data);
|
|
|
|
const char *
|
|
seaf_db_row_get_column_text (SeafDBRow *row, guint32 idx);
|
|
|
|
int
|
|
seaf_db_row_get_column_int (SeafDBRow *row, guint32 idx);
|
|
|
|
gint64
|
|
seaf_db_row_get_column_int64 (SeafDBRow *row, guint32 idx);
|
|
|
|
int
|
|
seaf_db_get_int (SeafDB *db, const char *sql);
|
|
|
|
gint64
|
|
seaf_db_get_int64 (SeafDB *db, const char *sql);
|
|
|
|
char *
|
|
seaf_db_get_string (SeafDB *db, const char *sql);
|
|
|
|
/* Transaction related */
|
|
|
|
SeafDBTrans *
|
|
seaf_db_begin_transaction (SeafDB *db);
|
|
|
|
void
|
|
seaf_db_trans_close (SeafDBTrans *trans);
|
|
|
|
int
|
|
seaf_db_commit (SeafDBTrans *trans);
|
|
|
|
int
|
|
seaf_db_rollback (SeafDBTrans *trans);
|
|
|
|
int
|
|
seaf_db_trans_query (SeafDBTrans *trans, const char *sql, int n, ...);
|
|
|
|
gboolean
|
|
seaf_db_trans_check_for_existence (SeafDBTrans *trans,
|
|
const char *sql,
|
|
gboolean *db_err,
|
|
int n, ...);
|
|
|
|
int
|
|
seaf_db_trans_foreach_selected_row (SeafDBTrans *trans, const char *sql,
|
|
SeafDBRowFunc callback, void *data,
|
|
int n, ...);
|
|
|
|
int
|
|
seaf_db_row_get_column_count (SeafDBRow *row);
|
|
|
|
/* Prepared Statements */
|
|
|
|
int
|
|
seaf_db_statement_query (SeafDB *db, const char *sql, int n, ...);
|
|
|
|
gboolean
|
|
seaf_db_statement_exists (SeafDB *db, const char *sql, gboolean *db_err, int n, ...);
|
|
|
|
int
|
|
seaf_db_statement_foreach_row (SeafDB *db, const char *sql,
|
|
SeafDBRowFunc callback, void *data,
|
|
int n, ...);
|
|
|
|
int
|
|
seaf_db_statement_get_int (SeafDB *db, const char *sql, int n, ...);
|
|
|
|
gint64
|
|
seaf_db_statement_get_int64 (SeafDB *db, const char *sql, int n, ...);
|
|
|
|
char *
|
|
seaf_db_statement_get_string (SeafDB *db, const char *sql, int n, ...);
|
|
|
|
#endif
|