summaryrefslogtreecommitdiff
path: root/sql/sql_sequence.h
diff options
context:
space:
mode:
authorMonty <monty@mariadb.org>2017-05-08 02:44:55 +0300
committerMonty <monty@mariadb.org>2017-05-08 02:44:55 +0300
commit71fa413c165e644f8f1433356f95fed12579fe3e (patch)
treef319474716dc55b3174fbf29a9dc510983d040a1 /sql/sql_sequence.h
parent1e04ad284c6ac0a9ce433f827bc6dbfbd6029007 (diff)
downloadmariadb-git-71fa413c165e644f8f1433356f95fed12579fe3e.tar.gz
MDEV-10139 Support for SEQUENCE objects
- SETVAL(sequence_name, next_value, is_used, round) - ALTER SEQUENCE, including RESTART WITH Other things: - Added handler::extra() option HA_EXTRA_PREPARE_FOR_ALTER_TABLE to signal ha_sequence() that it should allow write_row statments. - ALTER ONLINE TABLE now works with SEQUENCE:s
Diffstat (limited to 'sql/sql_sequence.h')
-rw-r--r--sql/sql_sequence.h37
1 files changed, 33 insertions, 4 deletions
diff --git a/sql/sql_sequence.h b/sql/sql_sequence.h
index 1409f86649f..ffe5ded4cff 100644
--- a/sql/sql_sequence.h
+++ b/sql/sql_sequence.h
@@ -20,6 +20,11 @@
#define seq_field_used_min_value 1
#define seq_field_used_max_value 2
#define seq_field_used_start 4
+#define seq_field_used_increment 8
+#define seq_field_used_cache 16
+#define seq_field_used_cycle 32
+#define seq_field_used_restart 64
+#define seq_field_used_restart_value 128
/**
sequence_definition is used when defining a sequence as part of create
@@ -41,11 +46,14 @@ public:
ulonglong round;
bool cycle;
uint used_fields; // Which fields where used in CREATE
+ longlong restart; // alter sequence restart value
bool check_and_adjust();
void store_fields(TABLE *table);
void read_fields(TABLE *table);
- void print_dbug()
+ int write_initial_sequence(TABLE *table);
+ int write(TABLE *table);
+ inline void print_dbug()
{
DBUG_PRINT("sequence", ("reserved: %lld start: %lld increment: %lld min_value: %lld max_value: %lld cache: %lld round: %lld",
reserved_until, start, increment, min_value,
@@ -80,13 +88,35 @@ public:
mysql_mutex_unlock(&mutex);
}
/* This must be called after sequence data has been updated */
- void adjust_values();
+ void adjust_values(longlong next_value);
void copy(sequence_definition *seq)
{
sequence_definition::operator= (*seq);
- adjust_values();
+ adjust_values(reserved_until);
}
longlong next_value(TABLE *table, bool second_round, int *error);
+ bool set_value(TABLE *table, longlong next_value, ulonglong round_arg,
+ bool is_used);
+ longlong increment_value(longlong value)
+ {
+ if (real_increment > 0)
+ {
+ if (value + real_increment > max_value ||
+ value > max_value - real_increment)
+ value= max_value + 1;
+ else
+ value+= real_increment;
+ }
+ else
+ {
+ if (value + real_increment < min_value ||
+ value < min_value - real_increment)
+ value= min_value - 1;
+ else
+ value+= real_increment;
+ }
+ return value;
+ }
bool all_values_used;
seq_init initialized;
@@ -100,7 +130,6 @@ private:
merged with global auto_increment_offset and auto_increment_increment
*/
longlong real_increment;
- longlong offset;
};