Skip to content

M
MariaDB
Commit af727451 authored by Olivier Bertrand's avatar Olivier Bertrand
Browse files
Options

Merge branch 'ob-10.1' into 10.1

parents c499f33b 5b998bf9
Hide whitespace changes
Inline Side-by-side
Showing with 484 additions and 309 deletions
storage/connect/ha_connect.cc
View file @ af727451
...@@ -1285,9 +1285,14 @@ PCSZ ha_connect::GetStringOption(PCSZ opname, PCSZ sdef) ...@@ -1285,9 +1285,14 @@ PCSZ ha_connect::GetStringOption(PCSZ opname, PCSZ sdef)
else else
opval= GetListOption(xp->g, opname, options->oplist); opval= GetListOption(xp->g, opname, options->oplist);
} else if (!stricmp(opname, "Query_String")) } else if (!stricmp(opname, "Query_String")) {
opval= thd_query_string(table->in_use)->str; // This escapes everything and returns a wrong query
else if (!stricmp(opname, "Partname")) // opval = thd_query_string(table->in_use)->str;
opval = (PCSZ)PlugSubAlloc(xp->g, NULL,
thd_query_string(table->in_use)->length + 1);
strcpy((char*)opval, thd_query_string(table->in_use)->str);
// sprintf((char*)opval, "%s", thd_query_string(table->in_use)->str);
} else if (!stricmp(opname, "Partname"))
opval= partname; opval= partname;
else if (!stricmp(opname, "Table_charset")) { else if (!stricmp(opname, "Table_charset")) {
const CHARSET_INFO *chif= (tshp) ? tshp->table_charset const CHARSET_INFO *chif= (tshp) ? tshp->table_charset
...@@ -1501,8 +1506,9 @@ void *ha_connect::GetColumnOption(PGLOBAL g, void *field, PCOLINFO pcf) ...@@ -1501,8 +1506,9 @@ void *ha_connect::GetColumnOption(PGLOBAL g, void *field, PCOLINFO pcf)
switch (pcf->Type) { switch (pcf->Type) {
case TYPE_STRING: case TYPE_STRING:
// Do something for case case TYPE_BIN:
cp= fp->charset()->name; // Do something for case
cp= chset;
// Find if collation name ends by _ci // Find if collation name ends by _ci
if (!strcmp(cp + strlen(cp) - 3, "_ci")) { if (!strcmp(cp + strlen(cp) - 3, "_ci")) {
...@@ -2114,6 +2120,11 @@ int ha_connect::MakeRecord(char *buf) ...@@ -2114,6 +2120,11 @@ int ha_connect::MakeRecord(char *buf)
charset= tdbp->data_charset(); charset= tdbp->data_charset();
rc= fp->store(p, strlen(p), charset, CHECK_FIELD_WARN); rc= fp->store(p, strlen(p), charset, CHECK_FIELD_WARN);
break; break;
case TYPE_BIN:
p = value->GetCharValue();
charset = &my_charset_bin;
rc = fp->store(p, strlen(p), charset, CHECK_FIELD_WARN);
break;
case TYPE_DOUBLE: case TYPE_DOUBLE:
rc= fp->store(value->GetFloatValue()); rc= fp->store(value->GetFloatValue());
break; break;
......
storage/connect/myconn.cpp
View file @ af727451
...@@ -472,7 +472,7 @@ int MYSQLC::Open(PGLOBAL g, const char *host, const char *db, ...@@ -472,7 +472,7 @@ int MYSQLC::Open(PGLOBAL g, const char *host, const char *db,
int pt, const char *csname) int pt, const char *csname)
{ {
const char *pipe = NULL; const char *pipe = NULL;
uint cto = 6000, nrt = 12000; uint cto = 10, nrt = 20;
my_bool my_true= 1; my_bool my_true= 1;
m_DB = mysql_init(NULL); m_DB = mysql_init(NULL);
...@@ -525,7 +525,8 @@ int MYSQLC::Open(PGLOBAL g, const char *host, const char *db, ...@@ -525,7 +525,8 @@ int MYSQLC::Open(PGLOBAL g, const char *host, const char *db,
mysql_options(m_DB, MYSQL_OPT_USE_THREAD_SPECIFIC_MEMORY, mysql_options(m_DB, MYSQL_OPT_USE_THREAD_SPECIFIC_MEMORY,
(char*)&my_true); (char*)&my_true);
if (!mysql_real_connect(m_DB, host, user, pwd, db, pt, pipe, CLIENT_MULTI_RESULTS)) { if (!mysql_real_connect(m_DB, host, user, pwd, db, pt, pipe,
CLIENT_MULTI_RESULTS | CLIENT_REMEMBER_OPTIONS)) {
#if defined(_DEBUG) #if defined(_DEBUG)
sprintf(g->Message, "mysql_real_connect failed: (%d) %s", sprintf(g->Message, "mysql_real_connect failed: (%d) %s",
mysql_errno(m_DB), mysql_error(m_DB)); mysql_errno(m_DB), mysql_error(m_DB));
......
storage/connect/mysql-test/connect/r/tbl_thread.result
View file @ af727451
...@@ -28,6 +28,22 @@ a b ...@@ -28,6 +28,22 @@ a b
9 test09 9 test09
10 test10 10 test10
11 test11 11 test11
CREATE TABLE rt4 (a int, b char(10));
INSERT INTO rt4 VALUES (12,'test12'),(13,'test13'),(14,'test14'),(15,'test15');
SELECT * FROM rt4;
a b
12 test12
13 test13
14 test14
15 test15
CREATE TABLE rt5 (a int, b char(10));
INSERT INTO rt5 VALUES (16,'test16'),(17,'test17'),(18,'test18'),(19,'test19');
SELECT * FROM rt5;
a b
16 test16
17 test17
18 test18
19 test19
CREATE TABLE t2 ENGINE=CONNECT TABLE_TYPE=MYSQL CREATE TABLE t2 ENGINE=CONNECT TABLE_TYPE=MYSQL
CONNECTION='mysql://root@127.0.0.1:MASTER_PORT/test/rt2'; CONNECTION='mysql://root@127.0.0.1:MASTER_PORT/test/rt2';
SELECT * FROM t2; SELECT * FROM t2;
...@@ -44,11 +60,35 @@ a b ...@@ -44,11 +60,35 @@ a b
9 test09 9 test09
10 test10 10 test10
11 test11 11 test11
CREATE TABLE t4 ENGINE=CONNECT TABLE_TYPE=MYSQL
CONNECTION='mysql://root@127.0.0.1:SLAVE_PORT/test/rt4';
SELECT * FROM t4;
a b
12 test12
13 test13
14 test14
15 test15
CREATE TABLE t5 ENGINE=CONNECT TABLE_TYPE=MYSQL
CONNECTION='mysql://root@127.0.0.1:SLAVE_PORT/test/rt5';
SELECT * FROM t5;
a b
16 test16
17 test17
18 test18
19 test19
CREATE TABLE total (a int, b char(10)) CREATE TABLE total (a int, b char(10))
ENGINE=CONNECT TABLE_TYPE=TBL TABLE_LIST='t1,t2,t3' ENGINE=CONNECT TABLE_TYPE=TBL TABLE_LIST='t1,t2,t3,t4,t5'
OPTION_LIST='thread=yes,port=PORT'; OPTION_LIST='thread=yes,port=PORT';
SELECT * FROM total order by a desc; SELECT * FROM total order by a desc;
a b a b
19 test19
18 test18
17 test17
16 test16
15 test15
14 test14
13 test13
12 test12
11 test11 11 test11
10 test10 10 test10
9 test09 9 test09
...@@ -62,8 +102,8 @@ a b ...@@ -62,8 +102,8 @@ a b
1 test01 1 test01
0 test00 0 test00
DROP TABLE rt2; DROP TABLE rt2;
DROP TABLE rt3; DROP TABLE rt3,rt4,rt5;
DROP TABLE t1,t2,t3,total; DROP TABLE t1,t2,t3,t4,t5,total;
# #
# Old thread TBL tables test modified # Old thread TBL tables test modified
# #
...@@ -84,6 +124,24 @@ DROP TABLE t1,t2,total; ...@@ -84,6 +124,24 @@ DROP TABLE t1,t2,total;
# #
# Old thread TBL tables test not modified (suppressed until MDEV-10179 is fixed) # Old thread TBL tables test not modified (suppressed until MDEV-10179 is fixed)
# #
CREATE TABLE t1 ENGINE=CONNECT TABLE_TYPE=MYSQL SRCDEF='select 11 as v';
SELECT * FROM t1;
v
11
CREATE TABLE t2 ENGINE=CONNECT TABLE_TYPE=MYSQL SRCDEF='select 22 as v';
SELECT * FROM t2;
v
22
CREATE TABLE total (v BIGINT(20) UNSIGNED NOT NULL) ENGINE=CONNECT TABLE_TYPE=TBL TABLE_LIST='t1,t2' OPTION_LIST='thread=yes,port=PORT';;
set connect_xtrace=1;
SELECT * FROM total order by v desc;
v
22
11
set connect_xtrace=0;
DROP TABLE total;
DROP TABLE t1;
DROP TABLE t2;
DROP TABLE IF EXISTS connect.t1; DROP TABLE IF EXISTS connect.t1;
DROP DATABASE IF EXISTS connect; DROP DATABASE IF EXISTS connect;
DROP TABLE IF EXISTS connect.t1; DROP TABLE IF EXISTS connect.t1;
......
storage/connect/mysql-test/connect/r/updelx.result
View file @ af727451
...@@ -986,108 +986,108 @@ DELETE FROM t1; ...@@ -986,108 +986,108 @@ DELETE FROM t1;
INSERT INTO t1 VALUES(4, 'four'),(7,'seven'),(10,'ten'),(40,'forty'),(60,'sixty'),(81,'eighty one'),(72,'seventy two'),(11,'eleven'),(1,'one'),(35,'thirty five'),(8,'eight'); INSERT INTO t1 VALUES(4, 'four'),(7,'seven'),(10,'ten'),(40,'forty'),(60,'sixty'),(81,'eighty one'),(72,'seventy two'),(11,'eleven'),(1,'one'),(35,'thirty five'),(8,'eight');
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 sixty 60 sixty
81 eighty one 81 eighty one
72 seventy two 72 seventy two
11 eleven 11 eleven
1 one 1 one
35 thirty five 35 thirty five
8 eight 8 eight
UPDATE t1 SET msg = 'bof' WHERE id = 35; UPDATE t1 SET msg = 'bof' WHERE id = 35;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 sixty 60 sixty
81 eighty one 81 eighty one
72 seventy two 72 seventy two
11 eleven 11 eleven
1 one 1 one
35 bof 35 bof
8 eight 8 eight
UPDATE t1 SET msg = 'big' WHERE id > 50; UPDATE t1 SET msg = 'big' WHERE id > 50;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 big 60 big
81 big 81 big
72 big 72 big
11 eleven 11 eleven
1 one 1 one
35 bof 35 bof
8 eight 8 eight
UPDATE t1 SET msg = 'updated' WHERE id IN (8,35,60,72); UPDATE t1 SET msg = 'updated' WHERE id IN (8,35,60,72);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 updated 60 updated
81 big 81 big
72 updated 72 updated
11 eleven 11 eleven
1 one 1 one
35 updated 35 updated
8 updated 8 updated
UPDATE t1 SET msg = 'twin' WHERE id IN (81,10); UPDATE t1 SET msg = 'twin' WHERE id IN (81,10);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 twin 10 twin
40 forty 40 forty
60 updated 60 updated
81 twin 81 twin
72 updated 72 updated
11 eleven 11 eleven
1 one 1 one
35 updated 35 updated
8 updated 8 updated
UPDATE t1 SET msg = 'sixty' WHERE id = 60; UPDATE t1 SET msg = 'sixty' WHERE id = 60;
SELECT * FROM t1 WHERE id = 60; SELECT * FROM t1 WHERE id = 60;
id msg id msg
60 sixty 60 sixty
DELETE FROM t1 WHERE id = 4; DELETE FROM t1 WHERE id = 4;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
7 seven 7 seven
10 twin 10 twin
40 forty 40 forty
60 sixty 60 sixty
81 twin 81 twin
72 updated 72 updated
11 eleven 11 eleven
1 one 1 one
35 updated 35 updated
8 updated 8 updated
DELETE FROM t1 WHERE id IN (40,11,35); DELETE FROM t1 WHERE id IN (40,11,35);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
7 seven 7 seven
10 twin 10 twin
60 sixty 60 sixty
81 twin 81 twin
72 updated 72 updated
1 one 1 one
8 updated 8 updated
DELETE FROM t1 WHERE id IN (4,60,1); DELETE FROM t1 WHERE id IN (4,60,1);
SELECT msg FROM t1; SELECT msg FROM t1;
msg msg
seven seven
twin twin
twin twin
updated updated
updated updated
DELETE FROM t1 WHERE id IN (81,72); DELETE FROM t1 WHERE id IN (81,72);
SELECT id FROM t1; SELECT id FROM t1;
id id
...@@ -1097,7 +1097,7 @@ id ...@@ -1097,7 +1097,7 @@ id
DELETE FROM t1 WHERE id IN (7,10); DELETE FROM t1 WHERE id IN (7,10);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
8 updated 8 updated
DELETE FROM t1 WHERE id = 8; DELETE FROM t1 WHERE id = 8;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
...@@ -1106,108 +1106,108 @@ DELETE FROM t1; ...@@ -1106,108 +1106,108 @@ DELETE FROM t1;
INSERT INTO t1 VALUES(4, 'four'),(7,'seven'),(10,'ten'),(40,'forty'),(60,'sixty'),(81,'eighty one'),(72,'seventy two'),(11,'eleven'),(1,'one'),(35,'thirty five'),(8,'eight'); INSERT INTO t1 VALUES(4, 'four'),(7,'seven'),(10,'ten'),(40,'forty'),(60,'sixty'),(81,'eighty one'),(72,'seventy two'),(11,'eleven'),(1,'one'),(35,'thirty five'),(8,'eight');
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 sixty 60 sixty
81 eighty one 81 eighty one
72 seventy two 72 seventy two
11 eleven 11 eleven
1 one 1 one
35 thirty five 35 thirty five
8 eight 8 eight
UPDATE t1 SET msg = 'bof' WHERE id = 35; UPDATE t1 SET msg = 'bof' WHERE id = 35;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 sixty 60 sixty
81 eighty one 81 eighty one
72 seventy two 72 seventy two
11 eleven 11 eleven
1 one 1 one
35 bof 35 bof
8 eight 8 eight
UPDATE t1 SET msg = 'big' WHERE id > 50; UPDATE t1 SET msg = 'big' WHERE id > 50;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 big 60 big
81 big 81 big
72 big 72 big
11 eleven 11 eleven
1 one 1 one
35 bof 35 bof
8 eight 8 eight
UPDATE t1 SET msg = 'updated' WHERE id IN (8,35,60,72); UPDATE t1 SET msg = 'updated' WHERE id IN (8,35,60,72);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 updated 60 updated
81 big 81 big
72 updated 72 updated
11 eleven 11 eleven
1 one 1 one
35 updated 35 updated
8 updated 8 updated
UPDATE t1 SET msg = 'twin' WHERE id IN (81,10); UPDATE t1 SET msg = 'twin' WHERE id IN (81,10);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 twin 10 twin
40 forty 40 forty
60 updated 60 updated
81 twin 81 twin
72 updated 72 updated
11 eleven 11 eleven
1 one 1 one
35 updated 35 updated
8 updated 8 updated
UPDATE t1 SET msg = 'sixty' WHERE id = 60; UPDATE t1 SET msg = 'sixty' WHERE id = 60;
SELECT * FROM t1 WHERE id = 60; SELECT * FROM t1 WHERE id = 60;
id msg id msg
60 sixty 60 sixty
DELETE FROM t1 WHERE id = 4; DELETE FROM t1 WHERE id = 4;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
7 seven 7 seven
10 twin 10 twin
40 forty 40 forty
60 sixty 60 sixty
81 twin 81 twin
72 updated 72 updated
11 eleven 11 eleven
1 one 1 one
35 updated 35 updated
8 updated 8 updated
DELETE FROM t1 WHERE id IN (40,11,35); DELETE FROM t1 WHERE id IN (40,11,35);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
7 seven 7 seven
10 twin 10 twin
60 sixty 60 sixty
81 twin 81 twin
72 updated 72 updated
1 one 1 one
8 updated 8 updated
DELETE FROM t1 WHERE id IN (4,60,1); DELETE FROM t1 WHERE id IN (4,60,1);
SELECT msg FROM t1; SELECT msg FROM t1;
msg msg
seven seven
twin twin
twin twin
updated updated
updated updated
DELETE FROM t1 WHERE id IN (81,72); DELETE FROM t1 WHERE id IN (81,72);
SELECT id FROM t1; SELECT id FROM t1;
id id
...@@ -1217,7 +1217,7 @@ id ...@@ -1217,7 +1217,7 @@ id
DELETE FROM t1 WHERE id IN (7,10); DELETE FROM t1 WHERE id IN (7,10);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
8 updated 8 updated
DELETE FROM t1 WHERE id = 8; DELETE FROM t1 WHERE id = 8;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
...@@ -1226,108 +1226,108 @@ DELETE FROM t1; ...@@ -1226,108 +1226,108 @@ DELETE FROM t1;
INSERT INTO t1 VALUES(4, 'four'),(7,'seven'),(10,'ten'),(40,'forty'),(60,'sixty'),(81,'eighty one'),(72,'seventy two'),(11,'eleven'),(1,'one'),(35,'thirty five'),(8,'eight'); INSERT INTO t1 VALUES(4, 'four'),(7,'seven'),(10,'ten'),(40,'forty'),(60,'sixty'),(81,'eighty one'),(72,'seventy two'),(11,'eleven'),(1,'one'),(35,'thirty five'),(8,'eight');
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 sixty 60 sixty
81 eighty one 81 eighty one
72 seventy two 72 seventy two
11 eleven 11 eleven
1 one 1 one
35 thirty five 35 thirty five
8 eight 8 eight
UPDATE t1 SET msg = 'bof' WHERE id = 35; UPDATE t1 SET msg = 'bof' WHERE id = 35;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 sixty 60 sixty
81 eighty one 81 eighty one
72 seventy two 72 seventy two
11 eleven 11 eleven
1 one 1 one
35 bof 35 bof
8 eight 8 eight
UPDATE t1 SET msg = 'big' WHERE id > 50; UPDATE t1 SET msg = 'big' WHERE id > 50;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 big 60 big
81 big 81 big
72 big 72 big
11 eleven 11 eleven
1 one 1 one
35 bof 35 bof
8 eight 8 eight
UPDATE t1 SET msg = 'updated' WHERE id IN (8,35,60,72); UPDATE t1 SET msg = 'updated' WHERE id IN (8,35,60,72);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 ten 10 ten
40 forty 40 forty
60 updated 60 updated
81 big 81 big
72 updated 72 updated
11 eleven 11 eleven
1 one 1 one
35 updated 35 updated
8 updated 8 updated
UPDATE t1 SET msg = 'twin' WHERE id IN (81,10); UPDATE t1 SET msg = 'twin' WHERE id IN (81,10);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
4 four 4 four
7 seven 7 seven
10 twin 10 twin
40 forty 40 forty
60 updated 60 updated
81 twin 81 twin
72 updated 72 updated
11 eleven 11 eleven
1 one 1 one
35 updated 35 updated
8 updated 8 updated
UPDATE t1 SET msg = 'sixty' WHERE id = 60; UPDATE t1 SET msg = 'sixty' WHERE id = 60;
SELECT * FROM t1 WHERE id = 60; SELECT * FROM t1 WHERE id = 60;
id msg id msg
60 sixty 60 sixty
DELETE FROM t1 WHERE id = 4; DELETE FROM t1 WHERE id = 4;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
7 seven 7 seven
10 twin 10 twin
40 forty 40 forty
60 sixty 60 sixty
81 twin 81 twin
72 updated 72 updated
11 eleven 11 eleven
1 one 1 one
35 updated 35 updated
8 updated 8 updated
DELETE FROM t1 WHERE id IN (40,11,35); DELETE FROM t1 WHERE id IN (40,11,35);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
7 seven 7 seven
10 twin 10 twin
60 sixty 60 sixty
81 twin 81 twin
72 updated 72 updated
1 one 1 one
8 updated 8 updated
DELETE FROM t1 WHERE id IN (4,60,1); DELETE FROM t1 WHERE id IN (4,60,1);
SELECT msg FROM t1; SELECT msg FROM t1;
msg msg
seven seven
twin twin
twin twin
updated updated
updated updated
DELETE FROM t1 WHERE id IN (81,72); DELETE FROM t1 WHERE id IN (81,72);
SELECT id FROM t1; SELECT id FROM t1;
id id
...@@ -1337,7 +1337,7 @@ id ...@@ -1337,7 +1337,7 @@ id
DELETE FROM t1 WHERE id IN (7,10); DELETE FROM t1 WHERE id IN (7,10);
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
8 updated 8 updated
DELETE FROM t1 WHERE id = 8; DELETE FROM t1 WHERE id = 8;
SELECT * FROM t1; SELECT * FROM t1;
id msg id msg
......
storage/connect/mysql-test/connect/t/tbl_thread.test
View file @ af727451
...@@ -2,8 +2,6 @@ ...@@ -2,8 +2,6 @@
connection default; connection default;
let $PORT= `select @@port`;
--echo # --echo #
--echo # Checking thread TBL tables --echo # Checking thread TBL tables
--echo # --echo #
...@@ -24,6 +22,14 @@ CREATE TABLE rt3 (a int, b char(10)); ...@@ -24,6 +22,14 @@ CREATE TABLE rt3 (a int, b char(10));
INSERT INTO rt3 VALUES (8,'test08'),(9,'test09'),(10,'test10'),(11,'test11'); INSERT INTO rt3 VALUES (8,'test08'),(9,'test09'),(10,'test10'),(11,'test11');
SELECT * FROM rt3; SELECT * FROM rt3;
CREATE TABLE rt4 (a int, b char(10));
INSERT INTO rt4 VALUES (12,'test12'),(13,'test13'),(14,'test14'),(15,'test15');
SELECT * FROM rt4;
CREATE TABLE rt5 (a int, b char(10));
INSERT INTO rt5 VALUES (16,'test16'),(17,'test17'),(18,'test18'),(19,'test19');
SELECT * FROM rt5;
connection default; connection default;
--replace_result $MASTER_MYPORT MASTER_PORT --replace_result $MASTER_MYPORT MASTER_PORT
...@@ -36,9 +42,19 @@ eval CREATE TABLE t3 ENGINE=CONNECT TABLE_TYPE=MYSQL ...@@ -36,9 +42,19 @@ eval CREATE TABLE t3 ENGINE=CONNECT TABLE_TYPE=MYSQL
CONNECTION='mysql://root@127.0.0.1:$SLAVE_MYPORT/test/rt3'; CONNECTION='mysql://root@127.0.0.1:$SLAVE_MYPORT/test/rt3';
SELECT * FROM t3; SELECT * FROM t3;
--replace_result $SLAVE_MYPORT SLAVE_PORT
eval CREATE TABLE t4 ENGINE=CONNECT TABLE_TYPE=MYSQL
CONNECTION='mysql://root@127.0.0.1:$SLAVE_MYPORT/test/rt4';
SELECT * FROM t4;
--replace_result $SLAVE_MYPORT SLAVE_PORT
eval CREATE TABLE t5 ENGINE=CONNECT TABLE_TYPE=MYSQL
CONNECTION='mysql://root@127.0.0.1:$SLAVE_MYPORT/test/rt5';
SELECT * FROM t5;
--replace_result $PORT PORT --replace_result $PORT PORT
eval CREATE TABLE total (a int, b char(10)) eval CREATE TABLE total (a int, b char(10))
ENGINE=CONNECT TABLE_TYPE=TBL TABLE_LIST='t1,t2,t3' ENGINE=CONNECT TABLE_TYPE=TBL TABLE_LIST='t1,t2,t3,t4,t5'
OPTION_LIST='thread=yes,port=$PORT'; OPTION_LIST='thread=yes,port=$PORT';
SELECT * FROM total order by a desc; SELECT * FROM total order by a desc;
...@@ -48,11 +64,11 @@ DROP TABLE rt2; ...@@ -48,11 +64,11 @@ DROP TABLE rt2;
connection slave; connection slave;
DROP TABLE rt3; DROP TABLE rt3,rt4,rt5;
connection default; connection default;
DROP TABLE t1,t2,t3,total; DROP TABLE t1,t2,t3,t4,t5,total;
--echo # --echo #
--echo # Old thread TBL tables test modified --echo # Old thread TBL tables test modified
...@@ -73,18 +89,20 @@ DROP TABLE t1,t2,total; ...@@ -73,18 +89,20 @@ DROP TABLE t1,t2,total;
--echo # --echo #
--echo # Old thread TBL tables test not modified (suppressed until MDEV-10179 is fixed) --echo # Old thread TBL tables test not modified (suppressed until MDEV-10179 is fixed)
--echo # --echo #
#CREATE TABLE t1 ENGINE=CONNECT TABLE_TYPE=MYSQL SRCDEF='select 11 as v'; CREATE TABLE t1 ENGINE=CONNECT TABLE_TYPE=MYSQL SRCDEF='select 11 as v';
#SELECT * FROM t1; SELECT * FROM t1;
#CREATE TABLE t2 ENGINE=CONNECT TABLE_TYPE=MYSQL SRCDEF='select 22 as v'; CREATE TABLE t2 ENGINE=CONNECT TABLE_TYPE=MYSQL SRCDEF='select 22 as v';
#SELECT * FROM t2; SELECT * FROM t2;
#--replace_result $PORT PORT --replace_result $PORT PORT
#--eval CREATE TABLE total (v BIGINT(20) UNSIGNED NOT NULL) ENGINE=CONNECT TABLE_TYPE=TBL TABLE_LIST='t1,t2' OPTION_LIST='thread=yes,port=$PORT'; --eval CREATE TABLE total (v BIGINT(20) UNSIGNED NOT NULL) ENGINE=CONNECT TABLE_TYPE=TBL TABLE_LIST='t1,t2' OPTION_LIST='thread=yes,port=$PORT';
#SELECT * FROM total order by v desc; set connect_xtrace=1;
SELECT * FROM total order by v desc;
set connect_xtrace=0;
#DROP TABLE total; DROP TABLE total;
#DROP TABLE t1; DROP TABLE t1;
#DROP TABLE t2; DROP TABLE t2;
-- source myconn_cleanup.inc -- source myconn_cleanup.inc
storage/connect/myutil.cpp
View file @ af727451
...@@ -218,7 +218,7 @@ int MYSQLtoPLG(int mytype, char *var) ...@@ -218,7 +218,7 @@ int MYSQLtoPLG(int mytype, char *var)
case MYSQL_TYPE_VARCHAR: case MYSQL_TYPE_VARCHAR:
#endif // !ALPHA) #endif // !ALPHA)
case MYSQL_TYPE_STRING: case MYSQL_TYPE_STRING:
type = TYPE_STRING; type = (*var == 'B') ? TYPE_BIN : TYPE_STRING;
break; break;
case MYSQL_TYPE_BLOB: case MYSQL_TYPE_BLOB:
case MYSQL_TYPE_TINY_BLOB: case MYSQL_TYPE_TINY_BLOB:
...@@ -232,7 +232,7 @@ int MYSQLtoPLG(int mytype, char *var) ...@@ -232,7 +232,7 @@ int MYSQLtoPLG(int mytype, char *var)
type = TYPE_STRING; type = TYPE_STRING;
*var = 'X'; *var = 'X';
} else } else
type = TYPE_ERROR; type = TYPE_BIN;
break; break;
case TPC_SKIP: case TPC_SKIP:
......
storage/connect/reldef.h
View file @ af727451
...@@ -94,6 +94,7 @@ class DllExport TABDEF : public RELDEF { /* Logical table descriptor */ ...@@ -94,6 +94,7 @@ class DllExport TABDEF : public RELDEF { /* Logical table descriptor */
virtual void SetIndx(PIXDEF) {} virtual void SetIndx(PIXDEF) {}
virtual bool IsHuge(void) {return false;} virtual bool IsHuge(void) {return false;}
const CHARSET_INFO *data_charset() {return m_data_charset;} const CHARSET_INFO *data_charset() {return m_data_charset;}
const char *GetCsName(void) {return csname;}
// Methods // Methods
int GetColCatInfo(PGLOBAL g); int GetColCatInfo(PGLOBAL g);
......
storage/connect/tabmysql.h
View file @ af727451
...@@ -69,6 +69,7 @@ class MYSQLDEF : public EXTDEF {/* Logical table description */ ...@@ -69,6 +69,7 @@ class MYSQLDEF : public EXTDEF {/* Logical table description */
/***********************************************************************/ /***********************************************************************/
class TDBMYSQL : public TDBEXT { class TDBMYSQL : public TDBEXT {
friend class MYSQLCOL; friend class MYSQLCOL;
friend class TDBTBM;
public: public:
// Constructor // Constructor
TDBMYSQL(PMYDEF tdp); TDBMYSQL(PMYDEF tdp);
......
storage/connect/tabtbl.cpp
View file @ af727451
...@@ -578,10 +578,19 @@ pthread_handler_t ThreadOpen(void *p) ...@@ -578,10 +578,19 @@ pthread_handler_t ThreadOpen(void *p)
// Try to open the connection // Try to open the connection
if (!cmp->Tap->GetTo_Tdb()->OpenDB(cmp->G)) { if (!cmp->Tap->GetTo_Tdb()->OpenDB(cmp->G)) {
pthread_mutex_lock(&tblmut); pthread_mutex_lock(&tblmut);
if (trace)
htrc("Table %s ready\n", cmp->Tap->GetName());
cmp->Ready = true; cmp->Ready = true;
pthread_mutex_unlock(&tblmut); pthread_mutex_unlock(&tblmut);
} else } else {
cmp->Rc = RC_FX; pthread_mutex_lock(&tblmut);
if (trace)
htrc("Opening %s failed\n", cmp->Tap->GetName());
cmp->Rc = RC_FX;
pthread_mutex_unlock(&tblmut);
} // endif OpenDB
my_thread_end(); my_thread_end();
} else } else
...@@ -632,6 +641,18 @@ int TDBTBM::RowNumber(PGLOBAL g, bool b) ...@@ -632,6 +641,18 @@ int TDBTBM::RowNumber(PGLOBAL g, bool b)
return Tdbp->RowNumber(g) + ((b) ? 0 : Rows); return Tdbp->RowNumber(g) + ((b) ? 0 : Rows);
} // end of RowNumber } // end of RowNumber
/***********************************************************************/
/* Returns true if this MYSQL table refers to a local table. */
/***********************************************************************/
bool TDBTBM::IsLocal(PTABLE tbp)
{
TDBMYSQL *tdbp = (TDBMYSQL*)tbp->GetTo_Tdb();
return ((!stricmp(tdbp->Host, "localhost") ||
!strcmp(tdbp->Host, "127.0.0.1")) &&
tdbp->Port == GetDefaultPort());
} // end of IsLocal
/***********************************************************************/ /***********************************************************************/
/* Initialyze table parallel processing. */ /* Initialyze table parallel processing. */
/***********************************************************************/ /***********************************************************************/
...@@ -644,10 +665,13 @@ bool TDBTBM::OpenTables(PGLOBAL g) ...@@ -644,10 +665,13 @@ bool TDBTBM::OpenTables(PGLOBAL g)
// Allocates the TBMT blocks for the tables // Allocates the TBMT blocks for the tables
for (tabp = Tablist; tabp; tabp = tabp->Next) for (tabp = Tablist; tabp; tabp = tabp->Next)
if (tabp->GetTo_Tdb()->GetAmType() == TYPE_AM_MYSQL) { if (tabp->GetTo_Tdb()->GetAmType() == TYPE_AM_MYSQL && !IsLocal(tabp)) {
// Remove remote table from the local list // Remove remote table from the local list
*ptabp = tabp->Next; *ptabp = tabp->Next;
if (trace)
htrc("=====> New remote table %s\n", tabp->GetName());
// Make the remote table block // Make the remote table block
tp = (PTBMT)PlugSubAlloc(g, NULL, sizeof(TBMT)); tp = (PTBMT)PlugSubAlloc(g, NULL, sizeof(TBMT));
memset(tp, 0, sizeof(TBMT)); memset(tp, 0, sizeof(TBMT));
...@@ -671,7 +695,10 @@ bool TDBTBM::OpenTables(PGLOBAL g) ...@@ -671,7 +695,10 @@ bool TDBTBM::OpenTables(PGLOBAL g)
ptp = &tp->Next; ptp = &tp->Next;
Nrc++; // Number of remote connections Nrc++; // Number of remote connections
} else { } else {
ptabp = &tabp->Next; if (trace)
htrc("=====> Local table %s\n", tabp->GetName());
ptabp = &tabp->Next;
Nlc++; // Number of local connections Nlc++; // Number of local connections
} // endif Type } // endif Type
...@@ -788,7 +815,7 @@ int TDBTBM::ReadDB(PGLOBAL g) ...@@ -788,7 +815,7 @@ int TDBTBM::ReadDB(PGLOBAL g)
/***********************************************************************/ /***********************************************************************/
int TDBTBM::ReadNextRemote(PGLOBAL g) int TDBTBM::ReadNextRemote(PGLOBAL g)
{ {
bool b = false; bool b;
if (Tdbp) if (Tdbp)
Tdbp->CloseDB(g); Tdbp->CloseDB(g);
...@@ -796,17 +823,22 @@ int TDBTBM::ReadNextRemote(PGLOBAL g) ...@@ -796,17 +823,22 @@ int TDBTBM::ReadNextRemote(PGLOBAL g)
Cmp = NULL; Cmp = NULL;
retry: retry:
// Search for a remote table having its result set b = false;
// Search for a remote table having its result set
pthread_mutex_lock(&tblmut); pthread_mutex_lock(&tblmut);
for (PTBMT tp = Tmp; tp; tp = tp->Next) for (PTBMT tp = Tmp; tp; tp = tp->Next)
if (tp->Ready) { if (tp->Rc != RC_FX) {
if (!tp->Complete) { if (tp->Ready) {
Cmp = tp; if (!tp->Complete) {
break; Cmp = tp;
} // endif Complete break;
} // endif Complete
} else } else
b = true; b = true;
} // endif Rc
pthread_mutex_unlock(&tblmut); pthread_mutex_unlock(&tblmut);
......
storage/connect/tabtbl.h
View file @ af727451
...@@ -146,6 +146,7 @@ class DllExport TDBTBM : public TDBTBL { ...@@ -146,6 +146,7 @@ class DllExport TDBTBM : public TDBTBL {
protected: protected:
// Internal functions // Internal functions
bool IsLocal(PTABLE tbp);
bool OpenTables(PGLOBAL g); bool OpenTables(PGLOBAL g);
int ReadNextRemote(PGLOBAL g); int ReadNextRemote(PGLOBAL g);
......
storage/connect/valblk.cpp
View file @ af727451
...@@ -59,11 +59,12 @@ PVBLK AllocValBlock(PGLOBAL g, void *mp, int type, int nval, int len, ...@@ -59,11 +59,12 @@ PVBLK AllocValBlock(PGLOBAL g, void *mp, int type, int nval, int len,
switch (type) { switch (type) {
case TYPE_STRING: case TYPE_STRING:
case TYPE_BIN:
case TYPE_DECIM: case TYPE_DECIM:
if (len) if (len)
blkp = new(g) CHRBLK(mp, nval, len, prec, blank); blkp = new(g) CHRBLK(mp, nval, type, len, prec, blank);
else else
blkp = new(g) STRBLK(g, mp, nval); blkp = new(g) STRBLK(g, mp, nval, type);
break; break;
case TYPE_SHORT: case TYPE_SHORT:
...@@ -615,8 +616,8 @@ int TYPBLK<TYPE>::GetMaxLength(void) ...@@ -615,8 +616,8 @@ int TYPBLK<TYPE>::GetMaxLength(void)
/***********************************************************************/ /***********************************************************************/
/* Constructor. */ /* Constructor. */
/***********************************************************************/ /***********************************************************************/
CHRBLK::CHRBLK(void *mp, int nval, int len, int prec, bool blank) CHRBLK::CHRBLK(void *mp, int nval, int type, int len, int prec, bool blank)
: VALBLK(mp, TYPE_STRING, nval), Chrp((char*&)Blkp) : VALBLK(mp, type, nval), Chrp((char*&)Blkp)
{ {
Valp = NULL; Valp = NULL;
Blanks = blank; Blanks = blank;
...@@ -1008,8 +1009,8 @@ int CHRBLK::GetMaxLength(void) ...@@ -1008,8 +1009,8 @@ int CHRBLK::GetMaxLength(void)
/***********************************************************************/ /***********************************************************************/
/* Constructor. */ /* Constructor. */
/***********************************************************************/ /***********************************************************************/
STRBLK::STRBLK(PGLOBAL g, void *mp, int nval) STRBLK::STRBLK(PGLOBAL g, void *mp, int nval, int type)
: VALBLK(mp, TYPE_STRING, nval), Strp((PSZ*&)Blkp) : VALBLK(mp, type, nval), Strp((PSZ*&)Blkp)
{ {
Global = g; Global = g;
Nullable = true; Nullable = true;
......
storage/connect/valblk.h
View file @ af727451
...@@ -214,7 +214,7 @@ class TYPBLK : public VALBLK { ...@@ -214,7 +214,7 @@ class TYPBLK : public VALBLK {
class CHRBLK : public VALBLK { class CHRBLK : public VALBLK {
public: public:
// Constructors // Constructors
CHRBLK(void *mp, int size, int len, int prec, bool b); CHRBLK(void *mp, int size, int type, int len, int prec, bool b);
// Implementation // Implementation
virtual bool Init(PGLOBAL g, bool check); virtual bool Init(PGLOBAL g, bool check);
...@@ -267,7 +267,7 @@ class CHRBLK : public VALBLK { ...@@ -267,7 +267,7 @@ class CHRBLK : public VALBLK {
class STRBLK : public VALBLK { class STRBLK : public VALBLK {
public: public:
// Constructors // Constructors
STRBLK(PGLOBAL g, void *mp, int size); STRBLK(PGLOBAL g, void *mp, int size, int type);
// Implementation // Implementation
virtual void SetNull(int n, bool b) {if (b) {Strp[n] = NULL;}} virtual void SetNull(int n, bool b) {if (b) {Strp[n] = NULL;}}
...@@ -345,7 +345,7 @@ class PTRBLK : public STRBLK { ...@@ -345,7 +345,7 @@ class PTRBLK : public STRBLK {
bool, bool, bool); bool, bool, bool);
protected: protected:
// Constructors // Constructors
PTRBLK(PGLOBAL g, void *mp, int size) : STRBLK(g, mp, size) {} PTRBLK(PGLOBAL g, void *mp, int size) : STRBLK(g, mp, size, TYPE_PCHAR) {}
// Implementation // Implementation
......
storage/connect/value.cpp
View file @ af727451
...@@ -236,6 +236,7 @@ bool IsTypeChar(int type) ...@@ -236,6 +236,7 @@ bool IsTypeChar(int type)
switch (type) { switch (type) {
case TYPE_STRING: case TYPE_STRING:
case TYPE_DECIM: case TYPE_DECIM:
case TYPE_BIN:
return true; return true;
} // endswitch type } // endswitch type
...@@ -1857,8 +1858,9 @@ int DECVAL::CompareValue(PVAL vp) ...@@ -1857,8 +1858,9 @@ int DECVAL::CompareValue(PVAL vp)
BINVAL::BINVAL(PGLOBAL g, void *p, int cl, int n) : VALUE(TYPE_BIN) BINVAL::BINVAL(PGLOBAL g, void *p, int cl, int n) : VALUE(TYPE_BIN)
{ {
assert(g); assert(g);
Len = n; //Len = n;
Clen = cl; Len = (g) ? n : (p) ? strlen((char*)p) : 0;
Clen = cl;
Binp = PlugSubAlloc(g, NULL, Clen + 1); Binp = PlugSubAlloc(g, NULL, Clen + 1);
memset(Binp, 0, Clen + 1); memset(Binp, 0, Clen + 1);
...@@ -1991,10 +1993,15 @@ bool BINVAL::SetValue_pval(PVAL valp, bool chktype) ...@@ -1991,10 +1993,15 @@ bool BINVAL::SetValue_pval(PVAL valp, bool chktype)
return true; return true;
if (!(Null = valp->IsNull() && Nullable)) { if (!(Null = valp->IsNull() && Nullable)) {
if ((rc = (Len = valp->GetSize()) > Clen)) int len = Len;
if ((rc = (Len = valp->GetSize()) > Clen))
Len = Clen; Len = Clen;
else if (len > Len)
memset(Binp, 0, len);
memcpy(Binp, valp->GetTo_Val(), Len); memcpy(Binp, valp->GetTo_Val(), Len);
((char*)Binp)[Len] = 0;
} else } else
Reset(); Reset();
...@@ -2011,10 +2018,15 @@ bool BINVAL::SetValue_char(const char *p, int n) ...@@ -2011,10 +2018,15 @@ bool BINVAL::SetValue_char(const char *p, int n)
bool rc; bool rc;
if (p && n > 0) { if (p && n > 0) {
rc = n > Clen; int len = Len;
Len = MY_MIN(n, Clen);
memcpy(Binp, p, Len); if (len > (Len = MY_MIN(n, Clen)))
Null = false; memset(Binp, 0, len);
memcpy(Binp, p, Len);
((char*)Binp)[Len] = 0;
rc = n > Clen;
Null = false;
} else { } else {
rc = false; rc = false;
Reset(); Reset();
...@@ -2030,9 +2042,14 @@ bool BINVAL::SetValue_char(const char *p, int n) ...@@ -2030,9 +2042,14 @@ bool BINVAL::SetValue_char(const char *p, int n)
void BINVAL::SetValue_psz(PCSZ s) void BINVAL::SetValue_psz(PCSZ s)
{ {
if (s) { if (s) {
Len = MY_MIN(Clen, (signed)strlen(s)); int len = Len;
memcpy(Binp, s, Len);
Null = false; if (len > (Len = MY_MIN(Clen, (signed)strlen(s))))
memset(Binp, 0, len);
memcpy(Binp, s, Len);
((char*)Binp)[Len] = 0;
Null = false;
} else { } else {
Reset(); Reset();
Null = Nullable; Null = Nullable;
...@@ -2052,14 +2069,19 @@ void BINVAL::SetValue_pvblk(PVBLK blk, int n) ...@@ -2052,14 +2069,19 @@ void BINVAL::SetValue_pvblk(PVBLK blk, int n)
Reset(); Reset();
Null = Nullable; Null = Nullable;
} else if (vp != Binp) { } else if (vp != Binp) {
int len = Len;
if (blk->GetType() == TYPE_STRING) if (blk->GetType() == TYPE_STRING)
Len = strlen((char*)vp); Len = strlen((char*)vp);
else else
Len = blk->GetVlen(); Len = blk->GetVlen();
Len = MY_MIN(Clen, Len); if (len > (Len = MY_MIN(Clen, Len)))
memset(Binp, 0, len);
memcpy(Binp, vp, Len); memcpy(Binp, vp, Len);
Null = false; ((char*)Binp)[Len] = 0;
Null = false;
} // endif vp } // endif vp
} // end of SetValue_pvblk } // end of SetValue_pvblk
...@@ -2070,7 +2092,10 @@ void BINVAL::SetValue_pvblk(PVBLK blk, int n) ...@@ -2070,7 +2092,10 @@ void BINVAL::SetValue_pvblk(PVBLK blk, int n)
void BINVAL::SetValue(int n) void BINVAL::SetValue(int n)
{ {
if (Clen >= 4) { if (Clen >= 4) {
*((int*)Binp) = n; if (Len > 4)
memset(Binp, 0, Len);
*((int*)Binp) = n;
Len = 4; Len = 4;
} else } else
SetValue((short)n); SetValue((short)n);
...@@ -2083,7 +2108,10 @@ void BINVAL::SetValue(int n) ...@@ -2083,7 +2108,10 @@ void BINVAL::SetValue(int n)
void BINVAL::SetValue(uint n) void BINVAL::SetValue(uint n)
{ {
if (Clen >= 4) { if (Clen >= 4) {
*((uint*)Binp) = n; if (Len > 4)
memset(Binp, 0, Len);
*((uint*)Binp) = n;
Len = 4; Len = 4;
} else } else
SetValue((ushort)n); SetValue((ushort)n);
...@@ -2096,7 +2124,10 @@ void BINVAL::SetValue(uint n) ...@@ -2096,7 +2124,10 @@ void BINVAL::SetValue(uint n)
void BINVAL::SetValue(short i) void BINVAL::SetValue(short i)
{ {
if (Clen >= 2) { if (Clen >= 2) {
*((int*)Binp) = i; if (Len > 2)
memset(Binp, 0, Len);
*((int*)Binp) = i;
Len = 2; Len = 2;
} else } else
SetValue((char)i); SetValue((char)i);
...@@ -2109,7 +2140,10 @@ void BINVAL::SetValue(short i) ...@@ -2109,7 +2140,10 @@ void BINVAL::SetValue(short i)
void BINVAL::SetValue(ushort i) void BINVAL::SetValue(ushort i)
{ {
if (Clen >= 2) { if (Clen >= 2) {
*((uint*)Binp) = i; if (Len > 2)
memset(Binp, 0, Len);
*((uint*)Binp) = i;
Len = 2; Len = 2;
} else } else
SetValue((uchar)i); SetValue((uchar)i);
...@@ -2122,7 +2156,10 @@ void BINVAL::SetValue(ushort i) ...@@ -2122,7 +2156,10 @@ void BINVAL::SetValue(ushort i)
void BINVAL::SetValue(longlong n) void BINVAL::SetValue(longlong n)
{ {
if (Clen >= 8) { if (Clen >= 8) {
*((longlong*)Binp) = n; if (Len > 8)
memset(Binp, 0, Len);
*((longlong*)Binp) = n;
Len = 8; Len = 8;
} else } else
SetValue((int)n); SetValue((int)n);
...@@ -2135,7 +2172,10 @@ void BINVAL::SetValue(longlong n) ...@@ -2135,7 +2172,10 @@ void BINVAL::SetValue(longlong n)
void BINVAL::SetValue(ulonglong n) void BINVAL::SetValue(ulonglong n)
{ {
if (Clen >= 8) { if (Clen >= 8) {
*((ulonglong*)Binp) = n; if (Len > 8)
memset(Binp, 0, Len);
*((ulonglong*)Binp) = n;
Len = 8; Len = 8;
} else } else
SetValue((uint)n); SetValue((uint)n);
...@@ -2146,6 +2186,9 @@ void BINVAL::SetValue(ulonglong n) ...@@ -2146,6 +2186,9 @@ void BINVAL::SetValue(ulonglong n)
/***********************************************************************/ /***********************************************************************/
void BINVAL::SetValue(double n) void BINVAL::SetValue(double n)
{ {
if (Len > 8)
memset(Binp, 0, Len);
if (Clen >= 8) { if (Clen >= 8) {
*((double*)Binp) = n; *((double*)Binp) = n;
Len = 8; Len = 8;
...@@ -2162,7 +2205,10 @@ void BINVAL::SetValue(double n) ...@@ -2162,7 +2205,10 @@ void BINVAL::SetValue(double n)
/***********************************************************************/ /***********************************************************************/
void BINVAL::SetValue(char c) void BINVAL::SetValue(char c)
{ {
*((char*)Binp) = c; if (Len > 1)
memset(Binp, 0, Len);
*((char*)Binp) = c;
Len = 1; Len = 1;
} // end of SetValue } // end of SetValue
...@@ -2171,7 +2217,10 @@ void BINVAL::SetValue(char c) ...@@ -2171,7 +2217,10 @@ void BINVAL::SetValue(char c)
/***********************************************************************/ /***********************************************************************/
void BINVAL::SetValue(uchar c) void BINVAL::SetValue(uchar c)
{ {
*((uchar*)Binp) = c; if (Len > 1)
memset(Binp, 0, Len);
*((uchar*)Binp) = c;
Len = 1; Len = 1;
} // end of SetValue } // end of SetValue
...@@ -2181,6 +2230,7 @@ void BINVAL::SetValue(uchar c) ...@@ -2181,6 +2230,7 @@ void BINVAL::SetValue(uchar c)
void BINVAL::SetBinValue(void *p) void BINVAL::SetBinValue(void *p)
{ {
memcpy(Binp, p, Clen); memcpy(Binp, p, Clen);
Len = Clen;
} // end of SetBinValue } // end of SetBinValue
/***********************************************************************/ /***********************************************************************/
...@@ -2206,10 +2256,11 @@ bool BINVAL::GetBinValue(void *buf, int buflen, bool go) ...@@ -2206,10 +2256,11 @@ bool BINVAL::GetBinValue(void *buf, int buflen, bool go)
/***********************************************************************/ /***********************************************************************/
char *BINVAL::ShowValue(char *buf, int len) char *BINVAL::ShowValue(char *buf, int len)
{ {
int n = MY_MIN(Len, len / 2); //int n = MY_MIN(Len, len / 2);
sprintf(buf, GetXfmt(), n, Binp); //sprintf(buf, GetXfmt(), n, Binp);
return buf; //return buf;
return (char*)Binp;
} // end of ShowValue } // end of ShowValue
/***********************************************************************/ /***********************************************************************/
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7