Add GObject wrapper classes for SQLite

We'll use them to implement the new history/bookmarks storage backend.

Code by Martin Robinson (mrobinson@igalia.com) and Claudio Saavedra
(csaavedra@igalia.com)

1 files changed, 269 insertions, 0 deletions

diff --git a/lib/ephy-sqlite-statement.c b/lib/ephy-sqlite-statement.c
new file mode 100644
index 000000000..f95518a2a
--- /dev/null
+++ b/lib/ephy-sqlite-statement.c
@@ -0,0 +1,269 @@
+/*
+ *  Copyright © 2011 Igalia S.L.
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2, or (at your option)
+ *  any later version.
+ *
+ *  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 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.
+ */
+
+#include "config.h"
+#include "ephy-sqlite-statement.h"
+
+#include "ephy-sqlite-connection.h"
+#include <sqlite3.h>
+
+enum
+{
+  PROP_0,
+  PROP_PREPARED_STATEMENT,
+  PROP_CONNECTION
+};
+
+struct _EphySQLiteStatementPrivate {
+  sqlite3_stmt *prepared_statement;
+  EphySQLiteConnection *connection;
+};
+
+#define EPHY_SQLITE_STATEMENT_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE((o), EPHY_TYPE_SQLITE_STATEMENT, EphySQLiteStatementPrivate))
+
+G_DEFINE_TYPE (EphySQLiteStatement, ephy_sqlite_statement, G_TYPE_OBJECT);
+
+static void
+ephy_sqlite_statement_set_property (GObject *object, guint property_id, const GValue *value, GParamSpec *pspec)
+{
+  EphySQLiteStatement *self = EPHY_SQLITE_STATEMENT (object);
+
+  switch (property_id) {
+    case PROP_PREPARED_STATEMENT:
+      self->priv->prepared_statement = g_value_get_pointer (value);
+      break;
+    case PROP_CONNECTION:
+      self->priv->connection = EPHY_SQLITE_CONNECTION (g_object_ref (g_value_get_object (value)));
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (self, property_id, pspec);
+      break;
+  }
+}
+
+static void
+ephy_sqlite_statement_get_property (GObject *object, guint property_id, GValue *value, GParamSpec *pspec)
+{
+  EphySQLiteStatement *self = EPHY_SQLITE_STATEMENT (object);
+
+  switch (property_id) {
+    case PROP_PREPARED_STATEMENT:
+      g_value_set_pointer (value, self->priv->prepared_statement);
+      break;
+    case PROP_CONNECTION:
+      g_value_set_object (value, self->priv->connection);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
+      break;
+  }
+}
+
+static void
+ephy_sqlite_statement_finalize (GObject *self)
+{
+  EphySQLiteStatementPrivate *priv = EPHY_SQLITE_STATEMENT (self)->priv;
+
+  if (priv->prepared_statement) {
+    sqlite3_finalize (priv->prepared_statement);
+    priv->prepared_statement = NULL;
+  }
+
+  if (priv->connection) {
+    g_object_unref (priv->connection);
+    priv->connection = NULL;
+  }
+
+  G_OBJECT_CLASS (ephy_sqlite_statement_parent_class)->dispose (self);
+}
+
+static void
+ephy_sqlite_statement_class_init (EphySQLiteStatementClass *klass)
+{
+  GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
+  gobject_class->finalize = ephy_sqlite_statement_finalize;
+  gobject_class->get_property = ephy_sqlite_statement_get_property;
+  gobject_class->set_property = ephy_sqlite_statement_set_property;
+  g_type_class_add_private (gobject_class, sizeof (EphySQLiteStatementPrivate));
+
+  g_object_class_install_property (gobject_class,
+                                   PROP_PREPARED_STATEMENT,
+                                   g_param_spec_pointer ("prepared-statement",
+                                                        "Prepared statement",
+                                                        "The statement's backing SQLite prepared statement",
+                                                        G_PARAM_CONSTRUCT_ONLY | G_PARAM_WRITABLE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
+
+  g_object_class_install_property (gobject_class,
+                                   PROP_CONNECTION,
+                                   g_param_spec_object ("connection",
+                                                        "Connection",
+                                                        "The statement's backing SQLite connection",
+                                                        EPHY_TYPE_SQLITE_CONNECTION,
+                                                        G_PARAM_CONSTRUCT_ONLY | G_PARAM_WRITABLE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
+}
+
+static void
+ephy_sqlite_statement_init (EphySQLiteStatement *self)
+{
+  self->priv = EPHY_SQLITE_STATEMENT_GET_PRIVATE (self);
+  self->priv->prepared_statement = NULL;
+  self->priv->connection = NULL;
+}
+
+gboolean
+ephy_sqlite_statement_bind_null (EphySQLiteStatement *self, int column, GError **error)
+{
+  if (sqlite3_bind_null (self->priv->prepared_statement, column) != SQLITE_OK) {
+    ephy_sqlite_connection_get_error (self->priv->connection, error);
+    return FALSE;
+  }
+
+  return TRUE;
+}
+
+gboolean
+ephy_sqlite_statement_bind_boolean (EphySQLiteStatement *self, int column, gboolean value, GError **error)
+{
+  if (sqlite3_bind_int (self->priv->prepared_statement, column + 1, value ? 1 : 0) != SQLITE_OK) {
+    ephy_sqlite_connection_get_error (self->priv->connection, error);
+    return FALSE;
+  }
+
+  return TRUE;
+}
+
+gboolean
+ephy_sqlite_statement_bind_int (EphySQLiteStatement *self, int column, int value, GError **error)
+{
+  if (sqlite3_bind_int (self->priv->prepared_statement, column + 1, value) != SQLITE_OK) {
+    ephy_sqlite_connection_get_error (self->priv->connection, error);
+    return FALSE;
+  }
+
+  return TRUE;
+}
+
+gboolean
+ephy_sqlite_statement_bind_double (EphySQLiteStatement *self, int column, double value, GError **error)
+{
+  if (sqlite3_bind_double (self->priv->prepared_statement, column + 1, value) != SQLITE_OK) {
+    ephy_sqlite_connection_get_error (self->priv->connection, error);
+    return FALSE;
+  }
+
+  return TRUE;
+}
+
+gboolean
+ephy_sqlite_statement_bind_string (EphySQLiteStatement *self, int column, const char *value, GError **error)
+{
+  if (sqlite3_bind_text (self->priv->prepared_statement, column + 1, value, -1, SQLITE_TRANSIENT) != SQLITE_OK) {
+    ephy_sqlite_connection_get_error (self->priv->connection, error);
+    return FALSE;
+  }
+
+  return TRUE;
+}
+
+gboolean
+ephy_sqlite_statement_bind_blob (EphySQLiteStatement *self, int column, const void *value, int length, GError **error)
+{
+  if (sqlite3_bind_blob (self->priv->prepared_statement, column + 1, value, length, SQLITE_TRANSIENT) != SQLITE_OK) {
+    ephy_sqlite_connection_get_error (self->priv->connection, error);
+    return FALSE;
+  }
+  return TRUE;
+}
+
+gboolean
+ephy_sqlite_statement_step (EphySQLiteStatement *self, GError **error)
+{
+  int error_code = sqlite3_step (self->priv->prepared_statement);
+  if (error_code != SQLITE_OK && error_code != SQLITE_ROW && error_code != SQLITE_DONE) {
+    ephy_sqlite_connection_get_error (self->priv->connection, error);
+  }
+
+  return error_code == SQLITE_ROW;
+}
+
+void
+ephy_sqlite_statement_reset (EphySQLiteStatement *self)
+{
+  sqlite3_reset (self->priv->prepared_statement);
+}
+
+int
+ephy_sqlite_statement_get_column_count (EphySQLiteStatement *self)
+{
+  return sqlite3_column_count (self->priv->prepared_statement);
+}
+
+EphySQLiteColumnType
+ephy_sqlite_statement_get_column_type (EphySQLiteStatement *self, int column)
+{
+  int column_type = sqlite3_column_type (self->priv->prepared_statement, column);
+  switch (column_type) {
+    case SQLITE_INTEGER:
+      return EPHY_SQLITE_COLUMN_TYPE_INT;
+    case SQLITE_FLOAT:
+      return EPHY_SQLITE_COLUMN_TYPE_FLOAT;
+    case SQLITE_TEXT:
+      return EPHY_SQLITE_COLUMN_TYPE_STRING;
+    case SQLITE_BLOB:
+      return EPHY_SQLITE_COLUMN_TYPE_BLOB;
+    case SQLITE_NULL:
+    default:
+      return EPHY_SQLITE_COLUMN_TYPE_NULL;
+  }
+}
+
+int
+ephy_sqlite_statement_get_column_size (EphySQLiteStatement *self, int column)
+{
+  return sqlite3_column_bytes (self->priv->prepared_statement, column);
+}
+
+int
+ephy_sqlite_statement_get_column_as_boolean (EphySQLiteStatement *self, int column)
+{
+  return ephy_sqlite_statement_get_column_as_int (self, column);
+}
+
+int
+ephy_sqlite_statement_get_column_as_int (EphySQLiteStatement *self, int column)
+{
+  return sqlite3_column_int (self->priv->prepared_statement, column);
+}
+
+double
+ephy_sqlite_statement_get_column_as_double (EphySQLiteStatement *self, int column)
+{
+  return sqlite3_column_double (self->priv->prepared_statement, column);
+}
+
+const char*
+ephy_sqlite_statement_get_column_as_string (EphySQLiteStatement *self, int column)
+{
+  return (const char*) sqlite3_column_text (self->priv->prepared_statement, column);
+}
+
+const void*
+ephy_sqlite_statement_get_column_as_blob (EphySQLiteStatement *self, int column)
+{
+  return sqlite3_column_blob (self->priv->prepared_statement, column);
+}