1berry/MariaDB-server
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge rkalimullin@bk-internal.mysql.com:/home/bk/mysql-5.1-maint

Browse Source 
into  mysql.com:/home/ram/work/mysql-5.1-maint
This commit is contained in:
unknown 2007-07-10 14:22:37 +05:00
commit 22531a8e7b
3 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mysql-test/r/csv.result
View File

@ -4945,6 +4945,8 @@ SELECT * FROM bug13894;
val val
6 6
6 6
5
11
DROP TABLE bug13894; DROP TABLE bug13894;
DROP TABLE IF EXISTS bug14672; DROP TABLE IF EXISTS bug14672;
CREATE TABLE bug14672 (c1 integer) engine = CSV; CREATE TABLE bug14672 (c1 integer) engine = CSV;

15
storage/csv/ha_tina.cc
View File

@ -904,6 +904,7 @@ int ha_tina::open_update_temp_file_if_needed()
0, O_RDWR | O_TRUNC, MYF(MY_WME))) < 0) 0, O_RDWR | O_TRUNC, MYF(MY_WME))) < 0)
return 1; return 1;
share->update_file_opened= TRUE; share->update_file_opened= TRUE;
temp_file_length= 0;
} }
return 0; return 0;
} }
@ -928,6 +929,13 @@ int ha_tina::update_row(const uchar * old_data, uchar * new_data)
size= encode_quote(new_data); size= encode_quote(new_data);
/*
During update we mark each updating record as deleted
(see the chain_append()) then write new one to the temporary data file.
At the end of the sequence in the rnd_end() we append all non-marked
records from the data file to the temporary data file then rename it.
The temp_file_length is used to calculate new data file length.
*/
if (chain_append()) if (chain_append())
DBUG_RETURN(-1); DBUG_RETURN(-1);
@ -937,6 +945,7 @@ int ha_tina::update_row(const uchar * old_data, uchar * new_data)
if (my_write(update_temp_file, (uchar*)buffer.ptr(), size, if (my_write(update_temp_file, (uchar*)buffer.ptr(), size,
MYF(MY_WME | MY_NABP))) MYF(MY_WME | MY_NABP)))
DBUG_RETURN(-1); DBUG_RETURN(-1);
temp_file_length+= size;
/* UPDATE should never happen on the log tables */ /* UPDATE should never happen on the log tables */
DBUG_ASSERT(!share->is_log_table); DBUG_ASSERT(!share->is_log_table);
@ -1154,7 +1163,6 @@ int ha_tina::rnd_end()
if ((chain_ptr - chain) > 0) if ((chain_ptr - chain) > 0)
{ {
off_t temp_file_length= 0;
tina_set *ptr= chain; tina_set *ptr= chain;
/* /*
@ -1244,7 +1252,10 @@ int ha_tina::rnd_end()
Here we record this fact to the meta-file. Here we record this fact to the meta-file.
*/ */
(void)write_meta_file(share->meta_file, share->rows_recorded, FALSE); (void)write_meta_file(share->meta_file, share->rows_recorded, FALSE);
/*
Update local_saved_data_file_length with the real length of the
data file.
*/
local_saved_data_file_length= temp_file_length; local_saved_data_file_length= temp_file_length;
} }

1
storage/csv/ha_tina.h
View File

@ -63,6 +63,7 @@ class ha_tina: public handler
off_t current_position; /* Current position in the file during a file scan */ off_t current_position; /* Current position in the file during a file scan */
off_t next_position; /* Next position in the file scan */ off_t next_position; /* Next position in the file scan */
off_t local_saved_data_file_length; /* save position for reads */ off_t local_saved_data_file_length; /* save position for reads */
off_t temp_file_length;
uchar byte_buffer[IO_SIZE]; uchar byte_buffer[IO_SIZE];
Transparent_file *file_buff; Transparent_file *file_buff;
File data_file; /* File handler for readers */ File data_file; /* File handler for readers */