add a table parameter "dsn" to Spider

1 files changed, 12 insertions, 0 deletions

diff --git a/storage/spider/spd_conn.cc b/storage/spider/spd_conn.cc
index 11cb46de985..100fe922825 100644
--- a/storage/spider/spd_conn.cc
+++ b/storage/spider/spd_conn.cc
@@ -566,6 +566,7 @@ SPIDER_CONN *spider_create_conn(
   char *tmp_name, *tmp_host, *tmp_username, *tmp_password, *tmp_socket;
   char *tmp_wrapper, *tmp_db, *tmp_ssl_ca, *tmp_ssl_capath, *tmp_ssl_cert;
   char *tmp_ssl_cipher, *tmp_ssl_key, *tmp_default_file, *tmp_default_group;
+  char *tmp_dsn;
   DBUG_ENTER("spider_create_conn");
 
   if (unlikely(!UTC))
@@ -615,6 +616,8 @@ SPIDER_CONN *spider_create_conn(
           (uint) (share->tgt_default_files_lengths[link_idx] + 1),
         &tmp_default_group,
           (uint) (share->tgt_default_groups_lengths[link_idx] + 1),
+        &tmp_dsn,
+          (uint) (share->tgt_dsns_lengths[link_idx] + 1),
         &need_mon, (uint) (sizeof(int)),
         NullS))
     ) {
@@ -714,6 +717,15 @@ SPIDER_CONN *spider_create_conn(
         share->tgt_default_groups_lengths[link_idx]);
     } else
       conn->tgt_default_group = NULL;
+    conn->tgt_dsn_length =
+      share->tgt_dsns_lengths[link_idx];
+    if (conn->tgt_dsn_length)
+    {
+      conn->tgt_dsn = tmp_dsn;
+      memcpy(conn->tgt_dsn, share->tgt_dsns[link_idx],
+        share->tgt_dsns_lengths[link_idx]);
+    } else
+      conn->tgt_dsn = NULL;
     conn->tgt_port = share->tgt_ports[link_idx];
     conn->tgt_ssl_vsc = share->tgt_ssl_vscs[link_idx];
     conn->dbton_id = share->sql_dbton_ids[link_idx];