1
1
/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
2
2
* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
4
* Copyright (C) 2009 Sun Microsystems
4
* Copyright (C) 2009 Sun Microsystems, Inc.
6
6
* This program is free software; you can redistribute it and/or modify
7
7
* it under the terms of the GNU General Public License as published by
21
21
#include "config.h"
22
22
#include <drizzled/show.h>
23
23
#include <drizzled/session.h>
24
#include <drizzled/session/cache.h>
24
25
#include <drizzled/statement/kill.h>
33
Kill::Kill(Session *in_session, Item *item, bool is_query_kill) :
38
getSession()->getLex()->type= ONLY_KILL_QUERY;
41
getSession()->getLex()->value_list.empty();
42
getSession()->getLex()->value_list.push_front(item);
43
getSession()->getLex()->sql_command= SQLCOM_KILL;
46
} // namespace statement
48
bool statement::Kill::kill(session_id_t id, bool only_kill_query)
50
drizzled::Session::shared_ptr session_param= session::Cache::singleton().find(id);
52
if (session_param and session_param->isViewable(*getSession()->user()))
54
session_param->awake(only_kill_query ? Session::KILL_QUERY : Session::KILL_CONNECTION);
29
61
bool statement::Kill::execute()
31
Item *it= (Item *) session->lex->value_list.head();
63
Item *it= (Item *) getSession()->lex->value_list.head();
33
if ((! it->fixed && it->fix_fields(session->lex->session, &it)) ||
65
if ((not it->fixed && it->fix_fields(getSession()->lex->session, &it)) || it->check_cols(1))
36
67
my_message(ER_SET_CONSTANTS_ONLY,
37
68
ER(ER_SET_CONSTANTS_ONLY),
41
sql_kill(session, (ulong) it->val_int(), session->lex->type & ONLY_KILL_QUERY);
73
if (kill(static_cast<session_id_t>(it->val_int()), getSession()->lex->type & ONLY_KILL_QUERY))
75
getSession()->my_ok();
79
my_error(ER_NO_SUCH_THREAD, MYF(0), it->val_int());