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
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
Kirill Smelkov
mariadb
Commits
c3b75121
Commit
c3b75121
authored
Jan 12, 2007
by
jonas@perch.ndb.mysql.com
Browse files
Options
Browse Files
Download
Plain Diff
Merge perch.ndb.mysql.com:/home/jonas/src/51-work
into perch.ndb.mysql.com:/home/jonas/src/mysql-5.1-new-ndb
parents
ef283377
f8fdb7c9
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
85 additions
and
3 deletions
+85
-3
mysql-test/r/ndb_partition_key.result
mysql-test/r/ndb_partition_key.result
+48
-0
mysql-test/t/ndb_partition_key.test
mysql-test/t/ndb_partition_key.test
+28
-0
storage/ndb/src/ndbapi/NdbScanOperation.cpp
storage/ndb/src/ndbapi/NdbScanOperation.cpp
+9
-3
No files found.
mysql-test/r/ndb_partition_key.result
View file @
c3b75121
...
...
@@ -203,3 +203,51 @@ NODEGROUP PARTITION_NAME
0 p0
0 p1
DROP TABLE t1;
CREATE TABLE t1 (
a tinyint unsigned NOT NULL,
b bigint(20) unsigned NOT NULL,
c char(12),
PRIMARY KEY (a,b)
) ENGINE ndb DEFAULT CHARSET=latin1 PARTITION BY KEY (a);
insert into t1 values(1,1,'1'), (2,2,'2'), (3,3,'3'), (4,4,'4'), (5,5,'5');
select * from t1 where a = 1;
a b c
1 1 1
select * from t1 where a = 2;
a b c
2 2 2
select * from t1 where a = 3;
a b c
3 3 3
select * from t1 where a = 4;
a b c
4 4 4
select * from t1 where a = 5;
a b c
5 5 5
delete from t1 where a = 1;
select * from t1 order by 1;
a b c
2 2 2
3 3 3
4 4 4
5 5 5
delete from t1 where a = 2;
select * from t1 order by 1;
a b c
3 3 3
4 4 4
5 5 5
delete from t1 where a = 3;
select * from t1 order by 1;
a b c
4 4 4
5 5 5
delete from t1 where a = 4;
select * from t1 order by 1;
a b c
5 5 5
delete from t1 where a = 5;
select * from t1 order by 1;
a b c
drop table t1;
mysql-test/t/ndb_partition_key.test
View file @
c3b75121
...
...
@@ -199,3 +199,31 @@ ALTER TABLE t1 ADD COLUMN c4 INT AFTER c1;
SELECT
NODEGROUP
,
PARTITION_NAME
FROM
information_schema
.
partitions
WHERE
table_name
=
"t1"
;
DROP
TABLE
t1
;
# bug#25587
CREATE
TABLE
t1
(
a
tinyint
unsigned
NOT
NULL
,
b
bigint
(
20
)
unsigned
NOT
NULL
,
c
char
(
12
),
PRIMARY
KEY
(
a
,
b
)
)
ENGINE
ndb
DEFAULT
CHARSET
=
latin1
PARTITION
BY
KEY
(
a
);
insert
into
t1
values
(
1
,
1
,
'1'
),
(
2
,
2
,
'2'
),
(
3
,
3
,
'3'
),
(
4
,
4
,
'4'
),
(
5
,
5
,
'5'
);
select
*
from
t1
where
a
=
1
;
select
*
from
t1
where
a
=
2
;
select
*
from
t1
where
a
=
3
;
select
*
from
t1
where
a
=
4
;
select
*
from
t1
where
a
=
5
;
delete
from
t1
where
a
=
1
;
select
*
from
t1
order
by
1
;
delete
from
t1
where
a
=
2
;
select
*
from
t1
order
by
1
;
delete
from
t1
where
a
=
3
;
select
*
from
t1
order
by
1
;
delete
from
t1
where
a
=
4
;
select
*
from
t1
order
by
1
;
delete
from
t1
where
a
=
5
;
select
*
from
t1
order
by
1
;
drop
table
t1
;
storage/ndb/src/ndbapi/NdbScanOperation.cpp
View file @
c3b75121
...
...
@@ -1187,25 +1187,31 @@ NdbIndexScanOperation::setBound(const NdbColumnImpl* tAttrInfo,
const
bool
nobytes
=
(
len
&
0x3
)
==
0
;
const
Uint32
totalLen
=
2
+
sizeInWords
;
Uint32
tupKeyLen
=
theTupKeyLen
;
union
{
Uint32
tempData
[
2000
];
Uint64
__align
;
};
Uint64
*
valPtr
;
if
(
remaining
>
totalLen
&&
aligned
&&
nobytes
){
Uint32
*
dst
=
theKEYINFOptr
+
currLen
;
*
dst
++
=
type
;
*
dst
++
=
ahValue
;
memcpy
(
dst
,
aValue
,
4
*
sizeInWords
);
theTotalNrOfKeyWordInSignal
=
currLen
+
totalLen
;
valPtr
=
(
Uint64
*
)
aValue
;
}
else
{
if
(
!
aligned
||
!
nobytes
){
Uint32
tempData
[
2000
];
tempData
[
0
]
=
type
;
tempData
[
1
]
=
ahValue
;
tempData
[
2
+
(
len
>>
2
)]
=
0
;
memcpy
(
tempData
+
2
,
aValue
,
len
);
insertBOUNDS
(
tempData
,
2
+
sizeInWords
);
valPtr
=
(
Uint64
*
)(
tempData
+
2
);
}
else
{
Uint32
buf
[
2
]
=
{
type
,
ahValue
};
insertBOUNDS
(
buf
,
2
);
insertBOUNDS
((
Uint32
*
)
aValue
,
sizeInWords
);
valPtr
=
(
Uint64
*
)
aValue
;
}
}
theTupKeyLen
=
tupKeyLen
+
totalLen
;
...
...
@@ -1222,7 +1228,7 @@ NdbIndexScanOperation::setBound(const NdbColumnImpl* tAttrInfo,
if
(
type
==
BoundEQ
&&
tDistrKey
)
{
theNoOfTupKeyLeft
--
;
return
handle_distribution_key
(
(
Uint64
*
)
aValue
,
sizeInWords
);
return
handle_distribution_key
(
valPtr
,
sizeInWords
);
}
return
0
;
}
else
{
...
...
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