The world's most popular open source database
00001 /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB 00002 00003 This program is free software; you can redistribute it and/or modify 00004 it under the terms of the GNU General Public License as published by 00005 the Free Software Foundation; either version 2 of the License, or 00006 (at your option) any later version. 00007 00008 This program is distributed in the hope that it will be useful, 00009 but WITHOUT ANY WARRANTY; without even the implied warranty of 00010 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 00011 GNU General Public License for more details. 00012 00013 You should have received a copy of the GNU General Public License 00014 along with this program; if not, write to the Free Software 00015 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ 00016 00017 00018 /* When using sql procedures */ 00019 00020 #ifdef USE_PRAGMA_INTERFACE 00021 #pragma interface /* gcc class implementation */ 00022 #endif 00023 00024 #define PROC_NO_SORT 1 /* Bits in flags */ 00025 #define PROC_GROUP 2 /* proc must have group */ 00026 00027 /* Procedure items used by procedures to store values for send_fields */ 00028 00029 class Item_proc :public Item 00030 { 00031 public: 00032 Item_proc(const char *name_par): Item() 00033 { 00034 this->name=(char*) name_par; 00035 } 00036 enum Type type() const { return Item::PROC_ITEM; } 00037 virtual void set(double nr)=0; 00038 virtual void set(const char *str,uint length,CHARSET_INFO *cs)=0; 00039 virtual void set(longlong nr)=0; 00040 virtual enum_field_types field_type() const=0; 00041 void set(const char *str) { set(str,(uint) strlen(str), default_charset()); } 00042 void make_field(Send_field *tmp_field) 00043 { 00044 init_make_field(tmp_field,field_type()); 00045 } 00046 unsigned int size_of() { return sizeof(*this);} 00047 }; 00048 00049 class Item_proc_real :public Item_proc 00050 { 00051 double value; 00052 public: 00053 Item_proc_real(const char *name_par,uint dec) : Item_proc(name_par) 00054 { 00055 decimals=dec; max_length=float_length(dec); 00056 } 00057 enum Item_result result_type () const { return REAL_RESULT; } 00058 enum_field_types field_type() const { return MYSQL_TYPE_DOUBLE; } 00059 void set(double nr) { value=nr; } 00060 void set(longlong nr) { value=(double) nr; } 00061 void set(const char *str,uint length,CHARSET_INFO *cs) 00062 { 00063 int err_not_used; 00064 char *end_not_used; 00065 value= my_strntod(cs,(char*) str,length, &end_not_used, &err_not_used); 00066 } 00067 double val_real() { return value; } 00068 longlong val_int() { return (longlong) value; } 00069 String *val_str(String *s) 00070 { 00071 s->set_real(value,decimals,default_charset()); 00072 return s; 00073 } 00074 my_decimal *val_decimal(my_decimal *); 00075 unsigned int size_of() { return sizeof(*this);} 00076 }; 00077 00078 class Item_proc_int :public Item_proc 00079 { 00080 longlong value; 00081 public: 00082 Item_proc_int(const char *name_par) :Item_proc(name_par) 00083 { max_length=11; } 00084 enum Item_result result_type () const { return INT_RESULT; } 00085 enum_field_types field_type() const { return MYSQL_TYPE_LONGLONG; } 00086 void set(double nr) { value=(longlong) nr; } 00087 void set(longlong nr) { value=nr; } 00088 void set(const char *str,uint length, CHARSET_INFO *cs) 00089 { int err; value=my_strntoll(cs,str,length,10,NULL,&err); } 00090 double val_real() { return (double) value; } 00091 longlong val_int() { return value; } 00092 String *val_str(String *s) { s->set(value, default_charset()); return s; } 00093 my_decimal *val_decimal(my_decimal *); 00094 unsigned int size_of() { return sizeof(*this);} 00095 }; 00096 00097 00098 class Item_proc_string :public Item_proc 00099 { 00100 public: 00101 Item_proc_string(const char *name_par,uint length) :Item_proc(name_par) 00102 { this->max_length=length; } 00103 enum Item_result result_type () const { return STRING_RESULT; } 00104 enum_field_types field_type() const { return MYSQL_TYPE_VARCHAR; } 00105 void set(double nr) { str_value.set_real(nr, 2, default_charset()); } 00106 void set(longlong nr) { str_value.set(nr, default_charset()); } 00107 void set(const char *str, uint length, CHARSET_INFO *cs) 00108 { str_value.copy(str,length,cs); } 00109 double val_real() 00110 { 00111 int err_not_used; 00112 char *end_not_used; 00113 CHARSET_INFO *cs= str_value.charset(); 00114 return my_strntod(cs, (char*) str_value.ptr(), str_value.length(), 00115 &end_not_used, &err_not_used); 00116 } 00117 longlong val_int() 00118 { 00119 int err; 00120 CHARSET_INFO *cs=str_value.charset(); 00121 return my_strntoll(cs,str_value.ptr(),str_value.length(),10,NULL,&err); 00122 } 00123 String *val_str(String*) 00124 { 00125 return null_value ? (String*) 0 : (String*) &str_value; 00126 } 00127 my_decimal *val_decimal(my_decimal *); 00128 unsigned int size_of() { return sizeof(*this);} 00129 }; 00130 00131 /* The procedure class definitions */ 00132 00133 class Procedure { 00134 protected: 00135 List<Item> *fields; 00136 select_result *result; 00137 public: 00138 const uint flags; 00139 ORDER *group,*param_fields; 00140 Procedure(select_result *res,uint flags_par) :result(res),flags(flags_par), 00141 group(0),param_fields(0) {} 00142 virtual ~Procedure() {group=param_fields=0; fields=0; } 00143 virtual void add(void)=0; 00144 virtual void end_group(void)=0; 00145 virtual int send_row(List<Item> &fields)=0; 00146 virtual bool change_columns(List<Item> &fields)=0; 00147 virtual void update_refs(void) {} 00148 virtual bool end_of_records() { return 0; } 00149 }; 00150 00151 Procedure *setup_procedure(THD *thd,ORDER *proc_param,select_result *result, 00152 List<Item> &field_list,int *error);
1.4.7

