From: Nikita Pettik <korablev@tarantool.org>
To: tarantool-patches@dev.tarantool.org
Cc: v.shpilevoy@tarantool.org
Subject: [Tarantool-patches] [PATCH 04/15] sql: rename sqlPrepare() to sql_compile()
Date: Thu, 7 Nov 2019 04:04:44 +0300 [thread overview]
Message-ID: <20191107010455.64457-5-korablev@tarantool.org> (raw)
In-Reply-To: <20191107010455.64457-1-korablev@tarantool.org>
sql_prepare() is going not only to compile statement, but also to save it
to the prepared statement cache. So we'd better rename sqlPrepare()
which is static wrapper around sql_prepare() and make it non-static.
Where it is possible let's use sql_compile() instead of sql_prepare().
Needed for #2592
---
src/box/execute.c | 2 +-
src/box/sql/analyze.c | 6 +++---
src/box/sql/legacy.c | 2 +-
src/box/sql/prepare.c | 21 ++++++---------------
src/box/sql/sqlInt.h | 13 +++++++++++++
5 files changed, 24 insertions(+), 20 deletions(-)
diff --git a/src/box/execute.c b/src/box/execute.c
index 0b21386b5..83680b70f 100644
--- a/src/box/execute.c
+++ b/src/box/execute.c
@@ -442,7 +442,7 @@ sql_prepare_and_execute(const char *sql, int len, const struct sql_bind *bind,
struct region *region)
{
struct sql_stmt *stmt;
- if (sql_prepare(sql, len, &stmt, NULL) != 0)
+ if (sql_compile(sql, len, NULL, &stmt, NULL) != 0)
return -1;
assert(stmt != NULL);
port_sql_create(port, stmt);
diff --git a/src/box/sql/analyze.c b/src/box/sql/analyze.c
index 9a66f8254..a887a2bf3 100644
--- a/src/box/sql/analyze.c
+++ b/src/box/sql/analyze.c
@@ -1360,7 +1360,7 @@ load_stat_from_space(const char *sql_select_prepare,
}
}
sql_stmt *stmt = NULL;
- int rc = sql_prepare(sql_select_prepare, -1, &stmt, 0);
+ int rc = sql_compile(sql_select_prepare, -1, NULL, &stmt, 0);
if (rc)
goto finalize;
uint32_t current_idx_count = 0;
@@ -1428,7 +1428,7 @@ load_stat_from_space(const char *sql_select_prepare,
rc = sql_finalize(stmt);
if (rc)
goto finalize;
- rc = sql_prepare(sql_select_load, -1, &stmt, 0);
+ rc = sql_compile(sql_select_load, -1, NULL, &stmt, 0);
if (rc)
goto finalize;
struct index *prev_index = NULL;
@@ -1510,7 +1510,7 @@ load_stat_to_index(const char *sql_select_load, struct index_stat **stats)
{
assert(stats != NULL && *stats != NULL);
struct sql_stmt *stmt = NULL;
- if (sql_prepare(sql_select_load, -1, &stmt, 0) != 0)
+ if (sql_compile(sql_select_load, -1, NULL, &stmt, 0) != 0)
return -1;
uint32_t current_idx_count = 0;
while (sql_step(stmt) == SQL_ROW) {
diff --git a/src/box/sql/legacy.c b/src/box/sql/legacy.c
index e3a2c77ca..93f927dea 100644
--- a/src/box/sql/legacy.c
+++ b/src/box/sql/legacy.c
@@ -71,7 +71,7 @@ sql_exec(sql * db, /* The database on which the SQL executes */
char **azVals = 0;
pStmt = 0;
- rc = sql_prepare(zSql, -1, &pStmt, &zLeftover);
+ rc = sql_compile(zSql, -1, NULL, &pStmt, &zLeftover);
assert(rc == 0 || pStmt == NULL);
if (rc != 0)
continue;
diff --git a/src/box/sql/prepare.c b/src/box/sql/prepare.c
index f72f9aa23..780085e56 100644
--- a/src/box/sql/prepare.c
+++ b/src/box/sql/prepare.c
@@ -39,18 +39,11 @@
#include "box/space.h"
#include "box/session.h"
-/*
- * Compile the UTF-8 encoded SQL statement zSql into a statement handle.
- */
-static int
-sqlPrepare(sql * db, /* Database handle. */
- const char *zSql, /* UTF-8 encoded SQL statement. */
- int nBytes, /* Length of zSql in bytes. */
- Vdbe * pReprepare, /* VM being reprepared */
- sql_stmt ** ppStmt, /* OUT: A pointer to the prepared statement */
- const char **pzTail /* OUT: End of parsed string */
- )
+int
+sql_compile(const char *zSql, int nBytes, struct Vdbe *pReprepare,
+ sql_stmt **ppStmt, const char **pzTail)
{
+ struct sql *db = sql_get();
int rc = 0; /* Result code */
Parse sParse; /* Parsing context */
sql_parser_create(&sParse, db, current_session()->sql_flags);
@@ -185,12 +178,10 @@ sqlReprepare(Vdbe * p)
{
sql_stmt *pNew;
const char *zSql;
- sql *db;
zSql = sql_sql((sql_stmt *) p);
assert(zSql != 0); /* Reprepare only called for prepare_v2() statements */
- db = sqlVdbeDb(p);
- if (sqlPrepare(db, zSql, -1, p, &pNew, 0) != 0) {
+ if (sql_compile(zSql, -1, p, &pNew, 0) != 0) {
assert(pNew == 0);
return -1;
}
@@ -206,7 +197,7 @@ int
sql_prepare(const char *sql, int length, struct sql_stmt **stmt,
const char **sql_tail)
{
- int rc = sqlPrepare(sql_get(), sql, length, 0, stmt, sql_tail);
+ int rc = sql_compile(sql, length, 0, stmt, sql_tail);
assert(rc == 0 || stmt == NULL || *stmt == NULL);
return rc;
}
diff --git a/src/box/sql/sqlInt.h b/src/box/sql/sqlInt.h
index 1bac252af..4a28e5fb9 100644
--- a/src/box/sql/sqlInt.h
+++ b/src/box/sql/sqlInt.h
@@ -459,6 +459,19 @@ typedef void (*sql_destructor_type) (void *);
#define SQL_STATIC ((sql_destructor_type)0)
#define SQL_TRANSIENT ((sql_destructor_type)-1)
+/**
+ * Compile the UTF-8 encoded SQL statement zSql into a statement handle.
+ *
+ * @param sql UTF-8 encoded SQL statement.
+ * @param sql_len Length of @sql in bytes.
+ * @param re_prepared VM being re-compiled. Can be NULL.
+ * @param[out] stmt A pointer to the compiled statement.
+ * @param[out] sql_tail End of parsed string.
+ */
+int
+sql_compile(const char *sql, int bytes_count, struct Vdbe *re_prepared,
+ sql_stmt **stmt, const char **sql_tail);
+
int
sql_step(sql_stmt *);
--
2.15.1
next prev parent reply other threads:[~2019-11-07 1:05 UTC|newest]
Thread overview: 23+ messages / expand[flat|nested] mbox.gz Atom feed top
2019-11-07 1:04 [Tarantool-patches] [PATCH 00/15] sql: prepared statements Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 01/15] sql: remove sql_prepare_v2() Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 02/15] sql: refactor sql_prepare() and sqlPrepare() Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 03/15] sql: move sql_prepare() declaration to box/execute.h Nikita Pettik
2019-11-07 1:04 ` Nikita Pettik [this message]
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 05/15] sql: move sql_finalize() to execute.h Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 06/15] port: increase padding of struct port Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 07/15] port: add dump format and request type to port_sql Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 08/15] sql: resurrect sql_bind_parameter_count() function Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 09/15] sql: resurrect sql_bind_parameter_name() Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 10/15] sql: add sql_schema_version() Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 11/15] sql: introduce sql_stmt_sizeof() function Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 12/15] box: increment schema_version on ddl operations Nikita Pettik
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 13/15] sql: introduce cache for prepared statemets Nikita Pettik
2019-11-10 23:40 ` Konstantin Osipov
2019-11-11 10:53 ` Nikita Pettik
2019-11-11 18:35 ` Konstantin Osipov
2019-11-12 7:54 ` Georgy Kirichenko
2019-11-12 8:50 ` Konstantin Osipov
2019-11-12 9:30 ` Georgy Kirichenko
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 14/15] box: introduce prepared statements Nikita Pettik
2019-11-10 23:42 ` Konstantin Osipov
2019-11-07 1:04 ` [Tarantool-patches] [PATCH 15/15] netbox: " Nikita Pettik
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=20191107010455.64457-5-korablev@tarantool.org \
--to=korablev@tarantool.org \
--cc=tarantool-patches@dev.tarantool.org \
--cc=v.shpilevoy@tarantool.org \
--subject='Re: [Tarantool-patches] [PATCH 04/15] sql: rename sqlPrepare() to sql_compile()' \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox