[sr-dev] git:master: modules/db_mysql: Implement affected_rows for mysql

[Alex Hermann]

Module: sip-router
Branch: master
Commit: 588d1ffbb7b6e5074e3dbb6950b2149544ea1521
URL:    http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=588d1ffbb7b6e5074e3dbb6950b2149544ea1521

Author: Alex Hermann <alex at speakup.nl>
Committer: Alex Hermann <alex at speakup.nl>
Date:   Tue Aug  9 11:58:01 2011 +0200

modules/db_mysql: Implement affected_rows for mysql

---

 modules/db_mysql/km_db_mysql.c |    2 +-
 modules/db_mysql/km_dbase.c    |   17 ++++++++++++++++-
 modules/db_mysql/km_dbase.h    |    7 +++++++
 3 files changed, 24 insertions(+), 2 deletions(-)

diff --git a/modules/db_mysql/km_db_mysql.c b/modules/db_mysql/km_db_mysql.c
index a94cf77..1f758ba 100644
--- a/modules/db_mysql/km_db_mysql.c
+++ b/modules/db_mysql/km_db_mysql.c
@@ -114,7 +114,7 @@ int db_mysql_bind_api(db_func_t *dbb)
 	dbb->last_inserted_id = db_mysql_last_inserted_id;
 	dbb->insert_update    = db_mysql_insert_update;
 	dbb->insert_delayed   = db_mysql_insert_delayed;
+	dbb->affected_rows    = db_mysql_affected_rows;
 
 	return 0;
 }
-
diff --git a/modules/db_mysql/km_dbase.c b/modules/db_mysql/km_dbase.c
index 68481f7..d85fe5f 100644
--- a/modules/db_mysql/km_dbase.c
+++ b/modules/db_mysql/km_dbase.c
@@ -480,7 +480,22 @@ int db_mysql_last_inserted_id(const db1_con_t* _h)
 }
 
 
- /**
+/**
+ * Returns the affected rows of the last query.
+ * \param _h database handle
+ * \return returns the affected rows as integer or -1 on error.
+ */
+int db_mysql_affected_rows(const db1_con_t* _h)
+{
+	if (!_h) {
+		LM_ERR("invalid parameter value\n");
+		return -1;
+	}
+	return (int)mysql_affected_rows(CON_CONNECTION(_h));
+}
+
+
+/**
   * Insert a row into a specified table, update on duplicate key.
   * \param _h structure representing database connection
   * \param _k key names
diff --git a/modules/db_mysql/km_dbase.h b/modules/db_mysql/km_dbase.h
index f7c2d0c..68e4e8e 100644
--- a/modules/db_mysql/km_dbase.h
+++ b/modules/db_mysql/km_dbase.h
@@ -111,6 +111,13 @@ int db_mysql_replace(const db1_con_t* handle, const db_key_t* keys, const db_val
  */
 int db_mysql_last_inserted_id(const db1_con_t* _h);
 
+
+/*! \brief
+ * Returns number of affected rows for last query
+ */
+int db_mysql_affected_rows(const db1_con_t* _h);
+
+
 /*! \brief
  * Insert a row into table, update on duplicate key
  */