Local merge.
This commit is contained in:
commit
48ecd65c52
@ -12706,3 +12706,14 @@ INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME='t1' AND TABLE_SCHEMA='test';
|
|||||||
DATA_LENGTH AVG_ROW_LENGTH
|
DATA_LENGTH AVG_ROW_LENGTH
|
||||||
8700 4350
|
8700 4350
|
||||||
DROP TABLE t1;
|
DROP TABLE t1;
|
||||||
|
SET @save_join_buffer_size= @@join_buffer_size;
|
||||||
|
SET @@join_buffer_size= 8228;
|
||||||
|
CREATE TABLE t1(a CHAR(255)) ENGINE=archive;
|
||||||
|
INSERT INTO t1 VALUES('aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa'),
|
||||||
|
('aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa'),
|
||||||
|
('aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa');
|
||||||
|
SELECT COUNT(t1.a) FROM t1, t1 a, t1 b, t1 c, t1 d, t1 e;
|
||||||
|
COUNT(t1.a)
|
||||||
|
729
|
||||||
|
DROP TABLE t1;
|
||||||
|
SET @@join_buffer_size= @save_join_buffer_size;
|
||||||
|
@ -1610,3 +1610,16 @@ INSERT INTO t1 VALUES(1, 'sampleblob1'),(2, 'sampleblob2');
|
|||||||
SELECT DATA_LENGTH, AVG_ROW_LENGTH FROM
|
SELECT DATA_LENGTH, AVG_ROW_LENGTH FROM
|
||||||
INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME='t1' AND TABLE_SCHEMA='test';
|
INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME='t1' AND TABLE_SCHEMA='test';
|
||||||
DROP TABLE t1;
|
DROP TABLE t1;
|
||||||
|
|
||||||
|
#
|
||||||
|
# BUG#46961 - archive engine loses rows during self joining select!
|
||||||
|
#
|
||||||
|
SET @save_join_buffer_size= @@join_buffer_size;
|
||||||
|
SET @@join_buffer_size= 8228;
|
||||||
|
CREATE TABLE t1(a CHAR(255)) ENGINE=archive;
|
||||||
|
INSERT INTO t1 VALUES('aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa'),
|
||||||
|
('aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa'),
|
||||||
|
('aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa');
|
||||||
|
SELECT COUNT(t1.a) FROM t1, t1 a, t1 b, t1 c, t1 d, t1 e;
|
||||||
|
DROP TABLE t1;
|
||||||
|
SET @@join_buffer_size= @save_join_buffer_size;
|
||||||
|
@ -993,6 +993,7 @@ int ha_archive::rnd_init(bool scan)
|
|||||||
/* We rewind the file so that we can read from the beginning if scan */
|
/* We rewind the file so that we can read from the beginning if scan */
|
||||||
if (scan)
|
if (scan)
|
||||||
{
|
{
|
||||||
|
scan_rows= stats.records;
|
||||||
DBUG_PRINT("info", ("archive will retrieve %llu rows",
|
DBUG_PRINT("info", ("archive will retrieve %llu rows",
|
||||||
(unsigned long long) scan_rows));
|
(unsigned long long) scan_rows));
|
||||||
|
|
||||||
@ -1461,7 +1462,6 @@ int ha_archive::info(uint flag)
|
|||||||
stats.records= share->rows_recorded;
|
stats.records= share->rows_recorded;
|
||||||
pthread_mutex_unlock(&share->mutex);
|
pthread_mutex_unlock(&share->mutex);
|
||||||
|
|
||||||
scan_rows= stats.records;
|
|
||||||
stats.deleted= 0;
|
stats.deleted= 0;
|
||||||
|
|
||||||
DBUG_PRINT("ha_archive", ("Stats rows is %d\n", (int)stats.records));
|
DBUG_PRINT("ha_archive", ("Stats rows is %d\n", (int)stats.records));
|
||||||
|
Loading…
x
Reference in New Issue
Block a user