aboutsummaryrefslogtreecommitdiff
path: root/src/sql.c
diff options
context:
space:
mode:
authorSergey Poznyakoff <gray@gnu.org>2020-04-10 21:04:21 +0300
committerSergey Poznyakoff <gray@gnu.org>2020-04-10 21:07:52 +0300
commita9da878ff22f980cea3bf3102113d7f2e65f61e9 (patch)
treedd3e21c580b91f6ab3d64e228ccb23170f3ddac3 /src/sql.c
parentda966c314f92d17b45ede9aa77ad3d3624c36725 (diff)
downloadwydawca-a9da878ff22f980cea3bf3102113d7f2e65f61e9.tar.gz
wydawca-a9da878ff22f980cea3bf3102113d7f2e65f61e9.tar.bz2
Change indentation to improve readability.
Diffstat (limited to 'src/sql.c')
-rw-r--r--src/sql.c240
1 files changed, 120 insertions, 120 deletions
diff --git a/src/sql.c b/src/sql.c
index e59b010..1381ff2 100644
--- a/src/sql.c
+++ b/src/sql.c
@@ -19,8 +19,8 @@
/* Singly-linked list of configured MySQL connections. */
struct sql_list {
- struct sql_list *next;
- struct sqlconn conn;
+ struct sql_list *next;
+ struct sqlconn conn;
};
static struct sql_list *sql_list;
@@ -29,175 +29,175 @@ static struct sql_list *sql_list;
void
sql_register_conn(struct sqlconn *conn)
{
- struct sql_list *ent = grecs_malloc(sizeof *ent);
- ent->conn = *conn;
- ent->next = sql_list;
- sql_list = ent;
+ struct sql_list *ent = grecs_malloc(sizeof *ent);
+ ent->conn = *conn;
+ ent->next = sql_list;
+ sql_list = ent;
}
/* Find a configured connection that has the given IDENT */
struct sqlconn *
sql_find_connection(const char *ident)
{
- struct sql_list *p;
- for (p = sql_list; p; p = p->next)
- if (strcmp(p->conn.ident, ident) == 0)
- return &p->conn;
- return NULL;
+ struct sql_list *p;
+ for (p = sql_list; p; p = p->next)
+ if (strcmp(p->conn.ident, ident) == 0)
+ return &p->conn;
+ return NULL;
}
/* Return true if there exists a connection with the given IDENT */
int
sql_connection_exists_p(const char *ident)
{
- return sql_find_connection(ident) != NULL;
+ return sql_find_connection(ident) != NULL;
}
/* Initialize MySQL dictionary */
int
sql_init_dictionary(struct dictionary *dict)
{
- struct sqlconn *conn = sql_find_connection(dict->parmv[0]);
-
- if (!conn) {
- wy_log(LOG_EMERG,
- _("INTERNAL ERROR: cannot find SQL connection %s"),
- dict->parmv[0]);
- abort();
- }
-
- if (conn->initcount++ == 0) {
- mysql_init(&conn->mysql);
-
- if (conn->config_file)
- mysql_options(&conn->mysql, MYSQL_READ_DEFAULT_FILE,
- conn->config_file);
- if (conn->config_group)
- mysql_options(&conn->mysql, MYSQL_READ_DEFAULT_GROUP,
- conn->config_group);
-
- if (conn->cacert)
- mysql_ssl_set(&conn->mysql, NULL, NULL, conn->cacert,
- NULL, NULL);
- if (!mysql_real_connect(&conn->mysql, conn->host, conn->user,
- conn->password, conn->database,
- conn->port, conn->socket,
- CLIENT_MULTI_RESULTS)) {
- wy_log(LOG_ERR,
- _("failed to connect to database %s: "
- "error: %s\n"),
- dict->parmv[0], mysql_error(&conn->mysql));
- return 1;
- }
+ struct sqlconn *conn = sql_find_connection(dict->parmv[0]);
+
+ if (!conn) {
+ wy_log(LOG_EMERG,
+ _("INTERNAL ERROR: cannot find SQL connection %s"),
+ dict->parmv[0]);
+ abort();
+ }
+
+ if (conn->initcount++ == 0) {
+ mysql_init(&conn->mysql);
+
+ if (conn->config_file)
+ mysql_options(&conn->mysql, MYSQL_READ_DEFAULT_FILE,
+ conn->config_file);
+ if (conn->config_group)
+ mysql_options(&conn->mysql, MYSQL_READ_DEFAULT_GROUP,
+ conn->config_group);
+
+ if (conn->cacert)
+ mysql_ssl_set(&conn->mysql, NULL, NULL, conn->cacert,
+ NULL, NULL);
+ if (!mysql_real_connect(&conn->mysql, conn->host, conn->user,
+ conn->password, conn->database,
+ conn->port, conn->socket,
+ CLIENT_MULTI_RESULTS)) {
+ wy_log(LOG_ERR,
+ _("failed to connect to database %s: "
+ "error: %s\n"),
+ dict->parmv[0], mysql_error(&conn->mysql));
+ return 1;
}
- dict->storage = conn;
- return 0;
+ }
+ dict->storage = conn;
+ return 0;
}
void *
sql_open(struct dictionary *dict)
{
- return dict->storage;
+ return dict->storage;
}
int
sql_free_result(struct dictionary *dict, void *handle)
{
- struct sqlconn *conn = handle;
- if (conn->result) {
- mysql_free_result(conn->result);
- conn->result = NULL;
- }
- return 0;
+ struct sqlconn *conn = handle;
+ if (conn->result) {
+ mysql_free_result(conn->result);
+ conn->result = NULL;
+ }
+ return 0;
}
/* Finish the initialized MySQL dictionary */
int
sql_done_dictionary(struct dictionary *dict)
{
- struct sqlconn *conn = dict->storage;
- if (!conn || conn->initcount == 0)
- return 0;
- if (--conn->initcount)
- return 0;
- sql_free_result(dict, conn); /* FIXME: Not needed */
- mysql_close(&conn->mysql);
- dict->storage = NULL;
+ struct sqlconn *conn = dict->storage;
+ if (!conn || conn->initcount == 0)
+ return 0;
+ if (--conn->initcount)
return 0;
+ sql_free_result(dict, conn); /* FIXME: Not needed */
+ mysql_close(&conn->mysql);
+ dict->storage = NULL;
+ return 0;
}
/* Execute QUERY using the given access METHOD. Return 0 on success. */
int
-sql_lookup_dictionary(struct dictionary *dict, void *handle, const char *query)
+sql_lookup_dictionary(struct dictionary *dict, void *handle,
+ const char *query)
{
- struct sqlconn *conn = handle;
- MYSQL *mysql = &conn->mysql;
-
- if (!query) {
- wy_log(LOG_ERR, _("no query supplied for dictionary %s"),
- "sql");
- return 1;
- }
-
- if (mysql_query(mysql, query)) {
- wy_log(LOG_ERR, _("query failed: %s"), mysql_error(mysql));
- wy_log(LOG_NOTICE, _("the failed query was: %s"), query);
- return 1;
- }
-
- conn->result = mysql_store_result(mysql);
- if (!conn->result) {
- wy_log(LOG_ERR, _("cannot get result: %s"), mysql_error(mysql));
- wy_log(LOG_NOTICE, _("the failed query was: %s"), query);
- return 1;
- }
-
- dict->nrow = mysql_num_rows(conn->result);
- dict->ncol = mysql_num_fields(conn->result);
- if (wy_debug_level > 1) {
- wy_log(LOG_DEBUG, _("query returned %u columns in %u rows"),
- dict->ncol, dict->nrow);
- wy_log(LOG_DEBUG, _("the query was: %s"), query);
- }
-
- return 0;
+ struct sqlconn *conn = handle;
+ MYSQL *mysql = &conn->mysql;
+
+ if (!query) {
+ wy_log(LOG_ERR, _("no query supplied for dictionary %s"), "sql");
+ return 1;
+ }
+
+ if (mysql_query(mysql, query)) {
+ wy_log(LOG_ERR, _("query failed: %s"), mysql_error(mysql));
+ wy_log(LOG_NOTICE, _("the failed query was: %s"), query);
+ return 1;
+ }
+
+ conn->result = mysql_store_result(mysql);
+ if (!conn->result) {
+ wy_log(LOG_ERR, _("cannot get result: %s"), mysql_error(mysql));
+ wy_log(LOG_NOTICE, _("the failed query was: %s"), query);
+ return 1;
+ }
+
+ dict->nrow = mysql_num_rows(conn->result);
+ dict->ncol = mysql_num_fields(conn->result);
+ if (wy_debug_level > 1) {
+ wy_log(LOG_DEBUG, _("query returned %u columns in %u rows"),
+ dict->ncol, dict->nrow);
+ wy_log(LOG_DEBUG, _("the query was: %s"), query);
+ }
+
+ return 0;
}
int
sql_get_dictionary(struct dictionary *dict, void *handle,
unsigned nrow, unsigned ncol)
{
- struct sqlconn *conn = handle;
- MYSQL_ROW row;
- size_t len;
-
- if (!conn->result)
- return 1;
- mysql_data_seek(conn->result, nrow);
- row = mysql_fetch_row(conn->result);
- if (row[ncol] == NULL)
- len = 0;
- else
- len = trim_length(row[ncol]);
-
- dictionary_copy_result(dict, row[ncol], len);
- return 0;
+ struct sqlconn *conn = handle;
+ MYSQL_ROW row;
+ size_t len;
+
+ if (!conn->result)
+ return 1;
+ mysql_data_seek(conn->result, nrow);
+ row = mysql_fetch_row(conn->result);
+ if (row[ncol] == NULL)
+ len = 0;
+ else
+ len = trim_length(row[ncol]);
+
+ dictionary_copy_result(dict, row[ncol], len);
+ return 0;
}
int
sql_quote(struct dictionary *dict, void *handle, const char *input,
char **poutput, size_t * psize)
{
- struct sqlconn *conn = handle;
- size_t len, size;
- char *output;
-
- len = strlen(input);
- size = 2 * len + 1;
- output = grecs_malloc(size);
- mysql_real_escape_string(&conn->mysql, output, input, len);
- *poutput = output;
- if (psize)
- *psize = strlen(output);
- return 0;
+ struct sqlconn *conn = handle;
+ size_t len, size;
+ char *output;
+
+ len = strlen(input);
+ size = 2 * len + 1;
+ output = grecs_malloc(size);
+ mysql_real_escape_string(&conn->mysql, output, input, len);
+ *poutput = output;
+ if (psize)
+ *psize = strlen(output);
+ return 0;
}

Return to:

Send suggestions and report system problems to the System administrator.