Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
M
MariaDB
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
nexedi
MariaDB
Commits
5745223a
Commit
5745223a
authored
Oct 01, 2004
by
tomas@poseidon.ndb.mysql.com
Browse files
Options
Browse Files
Download
Plain Diff
Merge tulin@bk-internal.mysql.com:/home/bk/mysql-4.1
into poseidon.ndb.mysql.com:/home/tomas/mysql-4.1
parents
c4c398bc
929e98b4
Changes
13
Hide whitespace changes
Inline
Side-by-side
Showing
13 changed files
with
225 additions
and
23 deletions
+225
-23
mysql-test/r/ndb_blob.result
mysql-test/r/ndb_blob.result
+21
-0
mysql-test/r/ndb_limit.result
mysql-test/r/ndb_limit.result
+41
-0
mysql-test/t/ndb_blob.test
mysql-test/t/ndb_blob.test
+18
-0
mysql-test/t/ndb_limit.test
mysql-test/t/ndb_limit.test
+38
-0
ndb/src/kernel/blocks/backup/restore/Restore.cpp
ndb/src/kernel/blocks/backup/restore/Restore.cpp
+8
-3
ndb/src/kernel/blocks/backup/restore/Restore.hpp
ndb/src/kernel/blocks/backup/restore/Restore.hpp
+45
-6
ndb/src/kernel/blocks/backup/restore/consumer.hpp
ndb/src/kernel/blocks/backup/restore/consumer.hpp
+1
-0
ndb/src/kernel/blocks/backup/restore/consumer_restore.cpp
ndb/src/kernel/blocks/backup/restore/consumer_restore.cpp
+26
-1
ndb/src/kernel/blocks/backup/restore/consumer_restore.hpp
ndb/src/kernel/blocks/backup/restore/consumer_restore.hpp
+1
-0
ndb/src/kernel/blocks/backup/restore/main.cpp
ndb/src/kernel/blocks/backup/restore/main.cpp
+14
-0
sql/ha_ndbcluster.cc
sql/ha_ndbcluster.cc
+6
-3
sql/ha_ndbcluster.h
sql/ha_ndbcluster.h
+1
-1
sql/sql_select.cc
sql/sql_select.cc
+5
-9
No files found.
mysql-test/r/ndb_blob.result
View file @
5745223a
...
@@ -377,3 +377,24 @@ count(*)
...
@@ -377,3 +377,24 @@ count(*)
0
0
drop table t1;
drop table t1;
drop database mysqltest;
drop database mysqltest;
set autocommit=1;
use test;
CREATE TABLE t1 (
a int,
b text,
PRIMARY KEY (a)
) ENGINE=MyISAM DEFAULT CHARSET=latin1;
INSERT INTO t1 VALUES
(1,'AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA');
INSERT INTO t1 VALUES
(2,'BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB');
select * from t1 order by a;
a b
1 AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
2 BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB
alter table t1 engine=ndb;
select * from t1 order by a;
a b
1 AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
2 BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB
drop table t1;
mysql-test/r/ndb_limit.result
View file @
5745223a
...
@@ -29,3 +29,44 @@ count(*)
...
@@ -29,3 +29,44 @@ count(*)
select * from t2 limit 0;
select * from t2 limit 0;
a b c
a b c
drop table t2;
drop table t2;
CREATE TABLE `t2` (
`views` int(11) NOT NULL default '0',
`clicks` int(11) NOT NULL default '0',
`day` date NOT NULL default '0000-00-00',
`hour` tinyint(4) NOT NULL default '0',
`bannerid` smallint(6) NOT NULL default '0',
`zoneid` smallint(6) NOT NULL default '0',
`source` varchar(50) NOT NULL default '',
PRIMARY KEY (`day`,`hour`,`bannerid`,`zoneid`,`source`),
KEY `bannerid_day` (`bannerid`,`day`),
KEY `zoneid` (`zoneid`)
) ENGINE=ndbcluster DEFAULT CHARSET=latin1;
INSERT INTO `t2` VALUES
( 1,0,'2004-09-17', 5,100,100,''),
( 1,0,'2004-09-18', 7,100,100,''),
( 17,0,'2004-09-27',20,132,100,''),
( 4,0,'2004-09-16',23,132,100,''),
( 86,0,'2004-09-18', 7,196,196,''),
( 11,0,'2004-09-16',16,132,100,''),
(140,0,'2004-09-18', 0,100,164,''),
( 2,0,'2004-09-17', 7,132,100,''),
(846,0,'2004-09-27',11,132,164,''),
( 1,0,'2004-09-18', 8,132,100,''),
( 22,0,'2004-09-27', 9,164,132,''),
(711,0,'2004-09-27', 9,100,164,''),
( 11,0,'2004-09-18', 0,196,132,''),
( 41,0,'2004-09-27',15,196,132,''),
( 57,0,'2004-09-18', 2,164,196,'');
SELECT DATE_FORMAT(day, '%Y%m%d') as date, DATE_FORMAT(day, '%d-%m-%Y')
as date_formatted FROM t2 GROUP BY day ORDER BY day DESC;
date date_formatted
20040927 27-09-2004
20040918 18-09-2004
20040917 17-09-2004
20040916 16-09-2004
SELECT DATE_FORMAT(day, '%Y%m%d') as date, DATE_FORMAT(day, '%d-%m-%Y')
as date_formatted FROM t2 GROUP BY day ORDER BY day DESC LIMIT 2;
date date_formatted
20040927 27-09-2004
20040918 18-09-2004
drop table t2;
mysql-test/t/ndb_blob.test
View file @
5745223a
...
@@ -308,3 +308,21 @@ rollback;
...
@@ -308,3 +308,21 @@ rollback;
select
count
(
*
)
from
t1
;
select
count
(
*
)
from
t1
;
drop
table
t1
;
drop
table
t1
;
drop
database
mysqltest
;
drop
database
mysqltest
;
set
autocommit
=
1
;
use
test
;
CREATE
TABLE
t1
(
a
int
,
b
text
,
PRIMARY
KEY
(
a
)
)
ENGINE
=
MyISAM
DEFAULT
CHARSET
=
latin1
;
INSERT
INTO
t1
VALUES
(
1
,
'AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA'
);
INSERT
INTO
t1
VALUES
(
2
,
'BBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBB'
);
select
*
from
t1
order
by
a
;
alter
table
t1
engine
=
ndb
;
select
*
from
t1
order
by
a
;
drop
table
t1
;
mysql-test/t/ndb_limit.test
View file @
5745223a
...
@@ -42,3 +42,41 @@ select count(*) from t2 where c=12345678 limit 1000;
...
@@ -42,3 +42,41 @@ select count(*) from t2 where c=12345678 limit 1000;
select
*
from
t2
limit
0
;
select
*
from
t2
limit
0
;
drop
table
t2
;
drop
table
t2
;
CREATE
TABLE
`t2`
(
`views`
int
(
11
)
NOT
NULL
default
'0'
,
`clicks`
int
(
11
)
NOT
NULL
default
'0'
,
`day`
date
NOT
NULL
default
'0000-00-00'
,
`hour`
tinyint
(
4
)
NOT
NULL
default
'0'
,
`bannerid`
smallint
(
6
)
NOT
NULL
default
'0'
,
`zoneid`
smallint
(
6
)
NOT
NULL
default
'0'
,
`source`
varchar
(
50
)
NOT
NULL
default
''
,
PRIMARY
KEY
(
`day`
,
`hour`
,
`bannerid`
,
`zoneid`
,
`source`
),
KEY
`bannerid_day`
(
`bannerid`
,
`day`
),
KEY
`zoneid`
(
`zoneid`
)
)
ENGINE
=
ndbcluster
DEFAULT
CHARSET
=
latin1
;
INSERT
INTO
`t2`
VALUES
(
1
,
0
,
'2004-09-17'
,
5
,
100
,
100
,
''
),
(
1
,
0
,
'2004-09-18'
,
7
,
100
,
100
,
''
),
(
17
,
0
,
'2004-09-27'
,
20
,
132
,
100
,
''
),
(
4
,
0
,
'2004-09-16'
,
23
,
132
,
100
,
''
),
(
86
,
0
,
'2004-09-18'
,
7
,
196
,
196
,
''
),
(
11
,
0
,
'2004-09-16'
,
16
,
132
,
100
,
''
),
(
140
,
0
,
'2004-09-18'
,
0
,
100
,
164
,
''
),
(
2
,
0
,
'2004-09-17'
,
7
,
132
,
100
,
''
),
(
846
,
0
,
'2004-09-27'
,
11
,
132
,
164
,
''
),
(
1
,
0
,
'2004-09-18'
,
8
,
132
,
100
,
''
),
(
22
,
0
,
'2004-09-27'
,
9
,
164
,
132
,
''
),
(
711
,
0
,
'2004-09-27'
,
9
,
100
,
164
,
''
),
(
11
,
0
,
'2004-09-18'
,
0
,
196
,
132
,
''
),
(
41
,
0
,
'2004-09-27'
,
15
,
196
,
132
,
''
),
(
57
,
0
,
'2004-09-18'
,
2
,
164
,
196
,
''
);
SELECT
DATE_FORMAT
(
day
,
'%Y%m%d'
)
as
date
,
DATE_FORMAT
(
day
,
'%d-%m-%Y'
)
as
date_formatted
FROM
t2
GROUP
BY
day
ORDER
BY
day
DESC
;
SELECT
DATE_FORMAT
(
day
,
'%Y%m%d'
)
as
date
,
DATE_FORMAT
(
day
,
'%d-%m-%Y'
)
as
date_formatted
FROM
t2
GROUP
BY
day
ORDER
BY
day
DESC
LIMIT
2
;
drop
table
t2
;
ndb/src/kernel/blocks/backup/restore/Restore.cpp
View file @
5745223a
...
@@ -88,7 +88,7 @@ RestoreMetaData::~RestoreMetaData(){
...
@@ -88,7 +88,7 @@ RestoreMetaData::~RestoreMetaData(){
allTables
.
clear
();
allTables
.
clear
();
}
}
const
TableS
*
TableS
*
RestoreMetaData
::
getTable
(
Uint32
tableId
)
const
{
RestoreMetaData
::
getTable
(
Uint32
tableId
)
const
{
for
(
Uint32
i
=
0
;
i
<
allTables
.
size
();
i
++
)
for
(
Uint32
i
=
0
;
i
<
allTables
.
size
();
i
++
)
if
(
allTables
[
i
]
->
getTableId
()
==
tableId
)
if
(
allTables
[
i
]
->
getTableId
()
==
tableId
)
...
@@ -201,6 +201,8 @@ TableS::TableS(NdbTableImpl* tableImpl)
...
@@ -201,6 +201,8 @@ TableS::TableS(NdbTableImpl* tableImpl)
{
{
m_dictTable
=
tableImpl
;
m_dictTable
=
tableImpl
;
m_noOfNullable
=
m_nullBitmaskSize
=
0
;
m_noOfNullable
=
m_nullBitmaskSize
=
0
;
m_auto_val_id
=
~
(
Uint32
)
0
;
m_max_auto_val
=
0
;
for
(
int
i
=
0
;
i
<
tableImpl
->
getNoOfColumns
();
i
++
)
for
(
int
i
=
0
;
i
<
tableImpl
->
getNoOfColumns
();
i
++
)
createAttr
(
tableImpl
->
getColumn
(
i
));
createAttr
(
tableImpl
->
getColumn
(
i
));
...
@@ -269,7 +271,7 @@ int TupleS::getNoOfAttributes() const {
...
@@ -269,7 +271,7 @@ int TupleS::getNoOfAttributes() const {
return
m_currentTable
->
getNoOfAttributes
();
return
m_currentTable
->
getNoOfAttributes
();
};
};
const
TableS
*
TupleS
::
getTable
()
const
{
TableS
*
TupleS
::
getTable
()
const
{
return
m_currentTable
;
return
m_currentTable
;
};
};
...
@@ -282,7 +284,7 @@ AttributeData * TupleS::getData(int i) const{
...
@@ -282,7 +284,7 @@ AttributeData * TupleS::getData(int i) const{
};
};
bool
bool
TupleS
::
prepareRecord
(
const
TableS
&
tab
){
TupleS
::
prepareRecord
(
TableS
&
tab
){
if
(
allAttrData
)
{
if
(
allAttrData
)
{
if
(
getNoOfAttributes
()
==
tab
.
getNoOfAttributes
())
if
(
getNoOfAttributes
()
==
tab
.
getNoOfAttributes
())
{
{
...
@@ -698,6 +700,9 @@ void TableS::createAttr(NdbDictionary::Column *column)
...
@@ -698,6 +700,9 @@ void TableS::createAttr(NdbDictionary::Column *column)
d
->
attrId
=
allAttributesDesc
.
size
();
d
->
attrId
=
allAttributesDesc
.
size
();
allAttributesDesc
.
push_back
(
d
);
allAttributesDesc
.
push_back
(
d
);
if
(
d
->
m_column
->
getAutoIncrement
())
m_auto_val_id
=
d
->
attrId
;
if
(
d
->
m_column
->
getPrimaryKey
()
/* && not variable */
)
if
(
d
->
m_column
->
getPrimaryKey
()
/* && not variable */
)
{
{
m_fixedKeys
.
push_back
(
d
);
m_fixedKeys
.
push_back
(
d
);
...
...
ndb/src/kernel/blocks/backup/restore/Restore.hpp
View file @
5745223a
...
@@ -91,9 +91,9 @@ class TupleS {
...
@@ -91,9 +91,9 @@ class TupleS {
private:
private:
friend
class
RestoreDataIterator
;
friend
class
RestoreDataIterator
;
const
TableS
*
m_currentTable
;
TableS
*
m_currentTable
;
AttributeData
*
allAttrData
;
AttributeData
*
allAttrData
;
bool
prepareRecord
(
const
TableS
&
);
bool
prepareRecord
(
TableS
&
);
public:
public:
TupleS
()
{
TupleS
()
{
...
@@ -108,7 +108,7 @@ public:
...
@@ -108,7 +108,7 @@ public:
TupleS
(
const
TupleS
&
tuple
);
// disable copy constructor
TupleS
(
const
TupleS
&
tuple
);
// disable copy constructor
TupleS
&
operator
=
(
const
TupleS
&
tuple
);
TupleS
&
operator
=
(
const
TupleS
&
tuple
);
int
getNoOfAttributes
()
const
;
int
getNoOfAttributes
()
const
;
const
TableS
*
getTable
()
const
;
TableS
*
getTable
()
const
;
const
AttributeDesc
*
getDesc
(
int
i
)
const
;
const
AttributeDesc
*
getDesc
(
int
i
)
const
;
AttributeData
*
getData
(
int
i
)
const
;
AttributeData
*
getData
(
int
i
)
const
;
};
// class TupleS
};
// class TupleS
...
@@ -130,6 +130,9 @@ class TableS {
...
@@ -130,6 +130,9 @@ class TableS {
Uint32
m_noOfNullable
;
Uint32
m_noOfNullable
;
Uint32
m_nullBitmaskSize
;
Uint32
m_nullBitmaskSize
;
Uint32
m_auto_val_id
;
Uint64
m_max_auto_val
;
int
pos
;
int
pos
;
void
createAttr
(
NdbDictionary
::
Column
*
column
);
void
createAttr
(
NdbDictionary
::
Column
*
column
);
...
@@ -170,6 +173,42 @@ public:
...
@@ -170,6 +173,42 @@ public:
return
allAttributesDesc
.
size
();
return
allAttributesDesc
.
size
();
};
};
bool
have_auto_inc
()
const
{
return
m_auto_val_id
!=
~
(
Uint32
)
0
;
};
bool
have_auto_inc
(
Uint32
id
)
const
{
return
m_auto_val_id
==
id
;
};
Uint64
get_max_auto_val
()
const
{
return
m_max_auto_val
;
};
void
update_max_auto_val
(
const
char
*
data
,
int
size
)
{
Uint64
val
=
0
;
switch
(
size
){
case
8
:
val
=
*
(
Uint8
*
)
data
;
break
;
case
16
:
val
=
*
(
Uint16
*
)
data
;
break
;
case
24
:
val
=
(
0xffffff
)
&*
(
Uint32
*
)
data
;
break
;
case
32
:
val
=
*
(
Uint32
*
)
data
;
break
;
case
64
:
val
=
*
(
Uint64
*
)
data
;
break
;
default:
return
;
};
if
(
val
>
m_max_auto_val
)
m_max_auto_val
=
val
;
};
/**
/**
* Get attribute descriptor
* Get attribute descriptor
*/
*/
...
@@ -245,7 +284,7 @@ public:
...
@@ -245,7 +284,7 @@ public:
Uint32
getNoOfTables
()
const
{
return
allTables
.
size
();}
Uint32
getNoOfTables
()
const
{
return
allTables
.
size
();}
const
TableS
*
operator
[](
int
i
)
const
{
return
allTables
[
i
];}
const
TableS
*
operator
[](
int
i
)
const
{
return
allTables
[
i
];}
const
TableS
*
getTable
(
Uint32
tableId
)
const
;
TableS
*
getTable
(
Uint32
tableId
)
const
;
Uint32
getStopGCP
()
const
;
Uint32
getStopGCP
()
const
;
};
// RestoreMetaData
};
// RestoreMetaData
...
@@ -254,7 +293,7 @@ public:
...
@@ -254,7 +293,7 @@ public:
class
RestoreDataIterator
:
public
BackupFile
{
class
RestoreDataIterator
:
public
BackupFile
{
const
RestoreMetaData
&
m_metaData
;
const
RestoreMetaData
&
m_metaData
;
Uint32
m_count
;
Uint32
m_count
;
const
TableS
*
m_currentTable
;
TableS
*
m_currentTable
;
TupleS
m_tuple
;
TupleS
m_tuple
;
public:
public:
...
@@ -278,7 +317,7 @@ public:
...
@@ -278,7 +317,7 @@ public:
LE_UPDATE
LE_UPDATE
};
};
EntryType
m_type
;
EntryType
m_type
;
const
TableS
*
m_table
;
TableS
*
m_table
;
Vector
<
AttributeS
*>
m_values
;
Vector
<
AttributeS
*>
m_values
;
Vector
<
AttributeS
*>
m_values_e
;
Vector
<
AttributeS
*>
m_values_e
;
AttributeS
*
add_attr
()
{
AttributeS
*
add_attr
()
{
...
...
ndb/src/kernel/blocks/backup/restore/consumer.hpp
View file @
5745223a
...
@@ -30,6 +30,7 @@ public:
...
@@ -30,6 +30,7 @@ public:
virtual
void
endOfTuples
(){}
virtual
void
endOfTuples
(){}
virtual
void
logEntry
(
const
LogEntry
&
){}
virtual
void
logEntry
(
const
LogEntry
&
){}
virtual
void
endOfLogEntrys
(){}
virtual
void
endOfLogEntrys
(){}
virtual
bool
finalize_table
(
const
TableS
&
){
return
true
;}
};
};
#endif
#endif
ndb/src/kernel/blocks/backup/restore/consumer_restore.cpp
View file @
5745223a
...
@@ -130,6 +130,21 @@ BackupRestore::get_table(const NdbDictionary::Table* tab){
...
@@ -130,6 +130,21 @@ BackupRestore::get_table(const NdbDictionary::Table* tab){
return
m_cache
.
m_new_table
;
return
m_cache
.
m_new_table
;
}
}
bool
BackupRestore
::
finalize_table
(
const
TableS
&
table
){
bool
ret
=
true
;
if
(
!
m_restore
&&
!
m_restore_meta
)
return
ret
;
if
(
table
.
have_auto_inc
())
{
Uint64
max_val
=
table
.
get_max_auto_val
();
Uint64
auto_val
=
m_ndb
->
readAutoIncrementValue
(
get_table
(
table
.
m_dictTable
));
if
(
max_val
+
1
>
auto_val
||
auto_val
==
~
(
Uint64
)
0
)
ret
=
m_ndb
->
setAutoIncrementValue
(
get_table
(
table
.
m_dictTable
),
max_val
+
1
,
false
);
}
return
ret
;
}
bool
bool
BackupRestore
::
table
(
const
TableS
&
table
){
BackupRestore
::
table
(
const
TableS
&
table
){
if
(
!
m_restore
&&
!
m_restore_meta
)
if
(
!
m_restore
&&
!
m_restore_meta
)
...
@@ -179,6 +194,9 @@ BackupRestore::table(const TableS & table){
...
@@ -179,6 +194,9 @@ BackupRestore::table(const TableS & table){
err
<<
"Unable to find table: "
<<
split
[
2
].
c_str
()
<<
endl
;
err
<<
"Unable to find table: "
<<
split
[
2
].
c_str
()
<<
endl
;
return
false
;
return
false
;
}
}
if
(
m_restore_meta
){
m_ndb
->
setAutoIncrementValue
(
tab
,
~
(
Uint64
)
0
,
false
);
}
const
NdbDictionary
::
Table
*
null
=
0
;
const
NdbDictionary
::
Table
*
null
=
0
;
m_new_tables
.
fill
(
table
.
m_dictTable
->
getTableId
(),
null
);
m_new_tables
.
fill
(
table
.
m_dictTable
->
getTableId
(),
null
);
m_new_tables
[
table
.
m_dictTable
->
getTableId
()]
=
tab
;
m_new_tables
[
table
.
m_dictTable
->
getTableId
()]
=
tab
;
...
@@ -316,6 +334,10 @@ void BackupRestore::tuple_a(restore_callback_t *cb)
...
@@ -316,6 +334,10 @@ void BackupRestore::tuple_a(restore_callback_t *cb)
int
arraySize
=
attr_desc
->
arraySize
;
int
arraySize
=
attr_desc
->
arraySize
;
char
*
dataPtr
=
attr_data
->
string_value
;
char
*
dataPtr
=
attr_data
->
string_value
;
Uint32
length
=
(
size
*
arraySize
)
/
8
;
Uint32
length
=
(
size
*
arraySize
)
/
8
;
if
(
j
==
0
&&
tup
.
getTable
()
->
have_auto_inc
(
i
))
tup
.
getTable
()
->
update_max_auto_val
(
dataPtr
,
size
);
if
(
attr_desc
->
m_column
->
getPrimaryKey
())
if
(
attr_desc
->
m_column
->
getPrimaryKey
())
{
{
if
(
j
==
1
)
continue
;
if
(
j
==
1
)
continue
;
...
@@ -510,8 +532,11 @@ BackupRestore::logEntry(const LogEntry & tup)
...
@@ -510,8 +532,11 @@ BackupRestore::logEntry(const LogEntry & tup)
int
arraySize
=
attr
->
Desc
->
arraySize
;
int
arraySize
=
attr
->
Desc
->
arraySize
;
const
char
*
dataPtr
=
attr
->
Data
.
string_value
;
const
char
*
dataPtr
=
attr
->
Data
.
string_value
;
if
(
tup
.
m_table
->
have_auto_inc
(
attr
->
Desc
->
attrId
))
tup
.
m_table
->
update_max_auto_val
(
dataPtr
,
size
);
const
Uint32
length
=
(
size
/
8
)
*
arraySize
;
const
Uint32
length
=
(
size
/
8
)
*
arraySize
;
if
(
attr
->
Desc
->
m_column
->
getPrimaryKey
())
if
(
attr
->
Desc
->
m_column
->
getPrimaryKey
())
op
->
equal
(
attr
->
Desc
->
attrId
,
dataPtr
,
length
);
op
->
equal
(
attr
->
Desc
->
attrId
,
dataPtr
,
length
);
else
else
op
->
setValue
(
attr
->
Desc
->
attrId
,
dataPtr
,
length
);
op
->
setValue
(
attr
->
Desc
->
attrId
,
dataPtr
,
length
);
...
...
ndb/src/kernel/blocks/backup/restore/consumer_restore.hpp
View file @
5745223a
...
@@ -59,6 +59,7 @@ public:
...
@@ -59,6 +59,7 @@ public:
virtual
void
endOfTuples
();
virtual
void
endOfTuples
();
virtual
void
logEntry
(
const
LogEntry
&
);
virtual
void
logEntry
(
const
LogEntry
&
);
virtual
void
endOfLogEntrys
();
virtual
void
endOfLogEntrys
();
virtual
bool
finalize_table
(
const
TableS
&
);
void
connectToMysql
();
void
connectToMysql
();
Ndb
*
m_ndb
;
Ndb
*
m_ndb
;
bool
m_restore
;
bool
m_restore
;
...
...
ndb/src/kernel/blocks/backup/restore/main.cpp
View file @
5745223a
...
@@ -355,6 +355,20 @@ main(int argc, const char** argv)
...
@@ -355,6 +355,20 @@ main(int argc, const char** argv)
logIter
.
validateFooter
();
//not implemented
logIter
.
validateFooter
();
//not implemented
for
(
i
=
0
;
i
<
g_consumers
.
size
();
i
++
)
for
(
i
=
0
;
i
<
g_consumers
.
size
();
i
++
)
g_consumers
[
i
]
->
endOfLogEntrys
();
g_consumers
[
i
]
->
endOfLogEntrys
();
for
(
i
=
0
;
i
<
metaData
.
getNoOfTables
();
i
++
)
{
if
(
checkSysTable
(
metaData
[
i
]
->
getTableName
()))
{
for
(
Uint32
j
=
0
;
j
<
g_consumers
.
size
();
j
++
)
if
(
!
g_consumers
[
j
]
->
finalize_table
(
*
metaData
[
i
]))
{
ndbout_c
(
"Restore: Failed to finalize restore table: %s. "
"Exiting..."
,
metaData
[
i
]
->
getTableName
());
return
-
11
;
}
}
}
}
}
}
}
clearConsumers
();
clearConsumers
();
...
...
sql/ha_ndbcluster.cc
View file @
5745223a
...
@@ -399,7 +399,7 @@ int ha_ndbcluster::set_ndb_key(NdbOperation *ndb_op, Field *field,
...
@@ -399,7 +399,7 @@ int ha_ndbcluster::set_ndb_key(NdbOperation *ndb_op, Field *field,
*/
*/
int
ha_ndbcluster
::
set_ndb_value
(
NdbOperation
*
ndb_op
,
Field
*
field
,
int
ha_ndbcluster
::
set_ndb_value
(
NdbOperation
*
ndb_op
,
Field
*
field
,
uint
fieldnr
)
uint
fieldnr
,
bool
*
set_blob_value
)
{
{
const
byte
*
field_ptr
=
field
->
ptr
;
const
byte
*
field_ptr
=
field
->
ptr
;
uint32
pack_len
=
field
->
pack_length
();
uint32
pack_len
=
field
->
pack_length
();
...
@@ -444,6 +444,8 @@ int ha_ndbcluster::set_ndb_value(NdbOperation *ndb_op, Field *field,
...
@@ -444,6 +444,8 @@ int ha_ndbcluster::set_ndb_value(NdbOperation *ndb_op, Field *field,
(
unsigned
)
blob_ptr
,
blob_len
));
(
unsigned
)
blob_ptr
,
blob_len
));
DBUG_DUMP
(
"value"
,
(
char
*
)
blob_ptr
,
min
(
blob_len
,
26
));
DBUG_DUMP
(
"value"
,
(
char
*
)
blob_ptr
,
min
(
blob_len
,
26
));
if
(
set_blob_value
)
*
set_blob_value
=
true
;
// No callback needed to write value
// No callback needed to write value
DBUG_RETURN
(
ndb_blob
->
setValue
(
blob_ptr
,
blob_len
)
!=
0
);
DBUG_RETURN
(
ndb_blob
->
setValue
(
blob_ptr
,
blob_len
)
!=
0
);
}
}
...
@@ -1593,11 +1595,12 @@ int ha_ndbcluster::write_row(byte *record)
...
@@ -1593,11 +1595,12 @@ int ha_ndbcluster::write_row(byte *record)
}
}
// Set non-key attribute(s)
// Set non-key attribute(s)
bool
set_blob_value
=
false
;
for
(
i
=
0
;
i
<
table
->
fields
;
i
++
)
for
(
i
=
0
;
i
<
table
->
fields
;
i
++
)
{
{
Field
*
field
=
table
->
field
[
i
];
Field
*
field
=
table
->
field
[
i
];
if
(
!
(
field
->
flags
&
PRI_KEY_FLAG
)
&&
if
(
!
(
field
->
flags
&
PRI_KEY_FLAG
)
&&
set_ndb_value
(
op
,
field
,
i
))
set_ndb_value
(
op
,
field
,
i
,
&
set_blob_value
))
{
{
skip_auto_increment
=
true
;
skip_auto_increment
=
true
;
ERR_RETURN
(
op
->
getNdbError
());
ERR_RETURN
(
op
->
getNdbError
());
...
@@ -1616,7 +1619,7 @@ int ha_ndbcluster::write_row(byte *record)
...
@@ -1616,7 +1619,7 @@ int ha_ndbcluster::write_row(byte *record)
bulk_insert_not_flushed
=
true
;
bulk_insert_not_flushed
=
true
;
if
((
rows_to_insert
==
1
)
||
if
((
rows_to_insert
==
1
)
||
((
rows_inserted
%
bulk_insert_rows
)
==
0
)
||
((
rows_inserted
%
bulk_insert_rows
)
==
0
)
||
uses_blob_value
(
false
)
!=
0
)
set_blob_value
)
{
{
THD
*
thd
=
current_thd
;
THD
*
thd
=
current_thd
;
// Send rows to NDB
// Send rows to NDB
...
...
sql/ha_ndbcluster.h
View file @
5745223a
...
@@ -210,7 +210,7 @@ class ha_ndbcluster: public handler
...
@@ -210,7 +210,7 @@ class ha_ndbcluster: public handler
uint
fieldnr
,
const
byte
*
field_ptr
);
uint
fieldnr
,
const
byte
*
field_ptr
);
int
set_ndb_key
(
NdbOperation
*
,
Field
*
field
,
int
set_ndb_key
(
NdbOperation
*
,
Field
*
field
,
uint
fieldnr
,
const
byte
*
field_ptr
);
uint
fieldnr
,
const
byte
*
field_ptr
);
int
set_ndb_value
(
NdbOperation
*
,
Field
*
field
,
uint
fieldnr
);
int
set_ndb_value
(
NdbOperation
*
,
Field
*
field
,
uint
fieldnr
,
bool
*
set_blob_value
=
0
);
int
get_ndb_value
(
NdbOperation
*
,
Field
*
field
,
uint
fieldnr
,
byte
*
);
int
get_ndb_value
(
NdbOperation
*
,
Field
*
field
,
uint
fieldnr
,
byte
*
);
friend
int
g_get_ndb_blobs_value
(
NdbBlob
*
ndb_blob
,
void
*
arg
);
friend
int
g_get_ndb_blobs_value
(
NdbBlob
*
ndb_blob
,
void
*
arg
);
int
get_ndb_blobs_value
(
NdbBlob
*
last_ndb_blob
);
int
get_ndb_blobs_value
(
NdbBlob
*
last_ndb_blob
);
...
...
sql/sql_select.cc
View file @
5745223a
...
@@ -6923,7 +6923,10 @@ static int test_if_order_by_key(ORDER *order, TABLE *table, uint idx,
...
@@ -6923,7 +6923,10 @@ static int test_if_order_by_key(ORDER *order, TABLE *table, uint idx,
reverse
=
flag
;
// Remember if reverse
reverse
=
flag
;
// Remember if reverse
key_part
++
;
key_part
++
;
}
}
*
used_key_parts
=
(
uint
)
(
key_part
-
table
->
key_info
[
idx
].
key_part
);
uint
tmp
=
(
uint
)
(
key_part
-
table
->
key_info
[
idx
].
key_part
);
if
(
reverse
==
-
1
&&
!
(
table
->
file
->
index_flags
(
idx
,
tmp
-
1
,
1
)
&
HA_READ_PREV
))
DBUG_RETURN
(
0
);
*
used_key_parts
=
tmp
;
DBUG_RETURN
(
reverse
);
DBUG_RETURN
(
reverse
);
}
}
...
@@ -7120,10 +7123,6 @@ test_if_skip_sort_order(JOIN_TAB *tab,ORDER *order,ha_rows select_limit,
...
@@ -7120,10 +7123,6 @@ test_if_skip_sort_order(JOIN_TAB *tab,ORDER *order,ha_rows select_limit,
*/
*/
if
(
!
select
->
quick
->
reverse_sorted
())
if
(
!
select
->
quick
->
reverse_sorted
())
{
{
// here used_key_parts >0
if
(
!
(
table
->
file
->
index_flags
(
ref_key
,
used_key_parts
-
1
,
1
)
&
HA_READ_PREV
))
DBUG_RETURN
(
0
);
// Use filesort
// ORDER BY range_key DESC
// ORDER BY range_key DESC
QUICK_SELECT_DESC
*
tmp
=
new
QUICK_SELECT_DESC
(
select
->
quick
,
QUICK_SELECT_DESC
*
tmp
=
new
QUICK_SELECT_DESC
(
select
->
quick
,
used_key_parts
);
used_key_parts
);
...
@@ -7144,9 +7143,6 @@ test_if_skip_sort_order(JOIN_TAB *tab,ORDER *order,ha_rows select_limit,
...
@@ -7144,9 +7143,6 @@ test_if_skip_sort_order(JOIN_TAB *tab,ORDER *order,ha_rows select_limit,
Use a traversal function that starts by reading the last row
Use a traversal function that starts by reading the last row
with key part (A) and then traverse the index backwards.
with key part (A) and then traverse the index backwards.
*/
*/
if
(
!
(
table
->
file
->
index_flags
(
ref_key
,
used_key_parts
-
1
,
1
)
&
HA_READ_PREV
))
DBUG_RETURN
(
0
);
// Use filesort
tab
->
read_first_record
=
join_read_last_key
;
tab
->
read_first_record
=
join_read_last_key
;
tab
->
read_record
.
read_record
=
join_read_prev_same
;
tab
->
read_record
.
read_record
=
join_read_prev_same
;
/* fall through */
/* fall through */
...
@@ -7192,7 +7188,7 @@ test_if_skip_sort_order(JOIN_TAB *tab,ORDER *order,ha_rows select_limit,
...
@@ -7192,7 +7188,7 @@ test_if_skip_sort_order(JOIN_TAB *tab,ORDER *order,ha_rows select_limit,
if
(
keys
.
is_set
(
nr
))
if
(
keys
.
is_set
(
nr
))
{
{
int
flag
;
int
flag
;
if
(
(
flag
=
test_if_order_by_key
(
order
,
table
,
nr
,
&
not_used
)
))
if
(
flag
=
test_if_order_by_key
(
order
,
table
,
nr
,
&
not_used
))
{
{
if
(
!
no_changes
)
if
(
!
no_changes
)
{
{
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment