summaryrefslogtreecommitdiff
path: root/storage/cassandra
diff options
context:
space:
mode:
authorSergey Petrunya <psergey@askmonty.org>2012-08-23 21:16:01 +0400
committerSergey Petrunya <psergey@askmonty.org>2012-08-23 21:16:01 +0400
commit38a3df4a2c887b406a8adb2d55e2adb5b80a2748 (patch)
tree265c465735e6afc44f5657d50c124fc457cae4ef /storage/cassandra
parent38d4e02559ad33ae7c4e9258528d78a09e5e330b (diff)
downloadmariadb-git-38a3df4a2c887b406a8adb2d55e2adb5b80a2748.tar.gz
- Enable mapping of CHAR(n)
- preparations for support of bulk INSERT.
Diffstat (limited to 'storage/cassandra')
-rw-r--r--storage/cassandra/ha_cassandra.cc14
-rw-r--r--storage/cassandra/ha_cassandra.h5
2 files changed, 17 insertions, 2 deletions
diff --git a/storage/cassandra/ha_cassandra.cc b/storage/cassandra/ha_cassandra.cc
index d1006a6e816..29159828a97 100644
--- a/storage/cassandra/ha_cassandra.cc
+++ b/storage/cassandra/ha_cassandra.cc
@@ -527,7 +527,7 @@ ColumnDataConverter *map_field_to_validator(Field *field, const char *validator_
case MYSQL_TYPE_VAR_STRING:
case MYSQL_TYPE_VARCHAR:
- //case MYSQL_TYPE_STRING: <-- todo: should we allow end-padded 'CHAR(N)'?
+ case MYSQL_TYPE_STRING: // these are space padded strings.
if (!strcmp(validator_name, validator_blob) ||
!strcmp(validator_name, validator_ascii) ||
!strcmp(validator_name, validator_text))
@@ -893,7 +893,19 @@ int ha_cassandra::rnd_pos(uchar *buf, uchar *pos)
DBUG_RETURN(rc);
}
+#if 0
+void ha_cassandra::start_bulk_insert(ha_rows rows)
+{
+ /* Do nothing? */
+}
+
+int ha_cassandra::end_bulk_insert()
+{
+ // TODO!
+ return 0;
+}
+#endif
/////////////////////////////////////////////////////////////////////////////
// Dummy implementations start
/////////////////////////////////////////////////////////////////////////////
diff --git a/storage/cassandra/ha_cassandra.h b/storage/cassandra/ha_cassandra.h
index cca70814b1b..469440a0049 100644
--- a/storage/cassandra/ha_cassandra.h
+++ b/storage/cassandra/ha_cassandra.h
@@ -145,7 +145,10 @@ public:
*/
virtual double read_time(uint, uint, ha_rows rows)
{ return (double) rows / 20.0+1; }
-
+#if 0
+ virtual void start_bulk_insert(ha_rows rows);
+ virtual int end_bulk_insert();
+#endif
/*
Everything below are methods that we implement in ha_example.cc.