~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/item/sum.cc

  • Committer: LinuxJedi
  • Date: 2010-08-28 09:23:52 UTC
  • mto: (1738.1.1 build)
  • mto: This revision was merged to the branch mainline in revision 1739.
  • Revision ID: linuxjedi@linuxjedi-laptop-20100828092352-oe3zbtdy05kq9dtq
Make exit happen in main thread rather than signal handler thread thus avoiding a segfault due to a double kill of the signal handler thread

Show diffs side-by-side

added added

removed removed

Lines of Context:
11
11
 
12
12
   You should have received a copy of the GNU General Public License
13
13
   along with this program; if not, write to the Free Software
14
 
   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA */
 
14
   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
15
15
 
16
16
 
17
17
/**
33
33
#include <drizzled/item/sum.h>
34
34
#include <drizzled/field/decimal.h>
35
35
#include <drizzled/field/double.h>
36
 
#include <drizzled/field/int64.h>
 
36
#include <drizzled/field/int64_t.h>
37
37
#include <drizzled/field/date.h>
38
38
#include <drizzled/field/datetime.h>
39
39
 
508
508
                                  Table *table,
509
509
                                  uint32_t convert_blob_length)
510
510
{
511
 
  Field *field= NULL;
512
 
 
 
511
  Field *field;
513
512
  switch (result_type()) {
514
513
  case REAL_RESULT:
515
514
    field= new Field_double(max_length, maybe_null, name, decimals, true);
516
515
    break;
517
 
 
518
516
  case INT_RESULT:
519
 
    field= new field::Int64(max_length, maybe_null, name, unsigned_flag);
 
517
    field= new Field_int64_t(max_length, maybe_null, name, unsigned_flag);
520
518
    break;
521
 
 
522
519
  case STRING_RESULT:
523
520
    if (max_length/collation.collation->mbmaxlen <= 255 ||
524
521
        convert_blob_length > Field_varstring::MAX_SIZE ||
525
522
        !convert_blob_length)
526
 
    {
527
523
      return make_string_field(table);
528
 
    }
529
 
 
530
 
    table->setVariableWidth();
531
524
    field= new Field_varstring(convert_blob_length, maybe_null,
532
 
                               name, collation.collation);
 
525
                               name, table->getMutableShare(), collation.collation);
533
526
    break;
534
 
 
535
527
  case DECIMAL_RESULT:
536
528
    field= new Field_decimal(max_length, maybe_null, name,
537
 
                             decimals, unsigned_flag);
 
529
                                 decimals, unsigned_flag);
538
530
    break;
539
 
 
540
531
  case ROW_RESULT:
 
532
  default:
541
533
    // This case should never be choosen
542
534
    assert(0);
543
535
    return 0;
544
536
  }
545
 
 
546
537
  if (field)
547
538
    field->init(table);
548
 
 
549
539
  return field;
550
540
}
551
541
 
655
645
    */
656
646
    break;
657
647
  case ROW_RESULT:
 
648
  default:
658
649
    assert(0);
659
650
  }
660
651
  collation.set(item->collation);
693
684
    max_length= item->max_length;
694
685
    break;
695
686
  case ROW_RESULT:
 
687
  default:
696
688
    assert(0);
697
689
  };
698
690
  /* MIN/MAX can return NULL for empty set indepedent of the used column */
804
796
    break;
805
797
  case INT_RESULT:
806
798
  case DECIMAL_RESULT:
807
 
    {
808
 
      /* SUM result can't be longer than length(arg) + length(MAX_ROWS) */
809
 
      int precision= args[0]->decimal_precision() + DECIMAL_LONGLONG_DIGITS;
810
 
      max_length= my_decimal_precision_to_length(precision, decimals,
811
 
                                                 unsigned_flag);
812
 
      curr_dec_buff= 0;
813
 
      hybrid_type= DECIMAL_RESULT;
814
 
      my_decimal_set_zero(dec_buffs);
815
 
      break;
816
 
    }
 
799
  {
 
800
    /* SUM result can't be longer than length(arg) + length(MAX_ROWS) */
 
801
    int precision= args[0]->decimal_precision() + DECIMAL_LONGLONG_DIGITS;
 
802
    max_length= my_decimal_precision_to_length(precision, decimals,
 
803
                                               unsigned_flag);
 
804
    curr_dec_buff= 0;
 
805
    hybrid_type= DECIMAL_RESULT;
 
806
    my_decimal_set_zero(dec_buffs);
 
807
    break;
 
808
  }
817
809
  case ROW_RESULT:
 
810
  default:
818
811
    assert(0);
819
812
  }
 
813
  return;
820
814
}
821
815
 
822
816
 
970
964
    table_field_type= DRIZZLE_TYPE_DOUBLE;
971
965
    break;
972
966
  case INT_RESULT:
973
 
    /*
974
 
      Preserving int8, int16, int32 field types gives ~10% performance boost
975
 
      as the size of result tree becomes significantly smaller.
976
 
      Another speed up we gain by using int64_t for intermediate
977
 
      calculations. The range of int64 is enough to hold sum 2^32 distinct
978
 
      integers each <= 2^32.
979
 
    */
980
 
    if (table_field_type == DRIZZLE_TYPE_LONG)
981
 
    {
982
 
      val.traits= Hybrid_type_traits_fast_decimal::instance();
983
 
      break;
984
 
    }
985
 
    table_field_type= DRIZZLE_TYPE_LONGLONG;
986
 
    /* fallthrough */
 
967
  /*
 
968
    Preserving int8, int16, int32 field types gives ~10% performance boost
 
969
    as the size of result tree becomes significantly smaller.
 
970
    Another speed up we gain by using int64_t for intermediate
 
971
    calculations. The range of int64 is enough to hold sum 2^32 distinct
 
972
    integers each <= 2^32.
 
973
  */
 
974
  if (table_field_type == DRIZZLE_TYPE_LONG)
 
975
  {
 
976
    val.traits= Hybrid_type_traits_fast_decimal::instance();
 
977
    break;
 
978
  }
 
979
  table_field_type= DRIZZLE_TYPE_LONGLONG;
 
980
  /* fallthrough */
987
981
  case DECIMAL_RESULT:
988
982
    val.traits= Hybrid_type_traits_decimal::instance();
989
983
    if (table_field_type != DRIZZLE_TYPE_LONGLONG)
990
984
      table_field_type= DRIZZLE_TYPE_DECIMAL;
991
985
    break;
992
986
  case ROW_RESULT:
 
987
  default:
993
988
    assert(0);
994
989
  }
995
 
 
996
990
  val.traits->fix_length_and_dec(this, args[0]);
997
991
}
998
992
 
1031
1025
  field_def.init_for_tmp_table(table_field_type, args[0]->max_length,
1032
1026
                               args[0]->decimals, args[0]->maybe_null);
1033
1027
 
1034
 
  if (! (table= session->getInstanceTable(field_list)))
 
1028
  if (! (table= session->create_virtual_tmp_table(field_list)))
1035
1029
    return(true);
1036
1030
 
1037
1031
  /* XXX: check that the case of CHAR(0) works OK */
1261
1255
      The easiest way is to do this is to store both value in a string
1262
1256
      and unpack on access.
1263
1257
    */
1264
 
    table->setVariableWidth();
1265
1258
    field= new Field_varstring(((hybrid_type == DECIMAL_RESULT) ?
1266
1259
                                dec_bin_size : sizeof(double)) + sizeof(int64_t),
1267
 
                               0, name, &my_charset_bin);
 
1260
                               0, name, table->getMutableShare(), &my_charset_bin);
1268
1261
  }
1269
1262
  else if (hybrid_type == DECIMAL_RESULT)
1270
1263
    field= new Field_decimal(max_length, maybe_null, name,
1440
1433
    break;
1441
1434
  case INT_RESULT:
1442
1435
  case DECIMAL_RESULT:
1443
 
    {
1444
 
      int precision= args[0]->decimal_precision()*2 + prec_increment;
1445
 
      decimals= min(args[0]->decimals + prec_increment, (unsigned int) DECIMAL_MAX_SCALE);
1446
 
      max_length= my_decimal_precision_to_length(precision, decimals,
1447
 
                                                 unsigned_flag);
 
1436
  {
 
1437
    int precision= args[0]->decimal_precision()*2 + prec_increment;
 
1438
    decimals= min(args[0]->decimals + prec_increment, (unsigned int) DECIMAL_MAX_SCALE);
 
1439
    max_length= my_decimal_precision_to_length(precision, decimals,
 
1440
                                               unsigned_flag);
1448
1441
 
1449
 
      break;
1450
 
    }
 
1442
    break;
 
1443
  }
1451
1444
  case ROW_RESULT:
 
1445
  default:
1452
1446
    assert(0);
1453
1447
  }
 
1448
  return;
1454
1449
}
1455
1450
 
1456
1451
 
1476
1471
      The easiest way is to do this is to store both value in a string
1477
1472
      and unpack on access.
1478
1473
    */
1479
 
    table->setVariableWidth();
1480
 
    field= new Field_varstring(sizeof(double)*2 + sizeof(int64_t), 0, name, &my_charset_bin);
 
1474
    field= new Field_varstring(sizeof(double)*2 + sizeof(int64_t), 0, name, table->getMutableShare(), &my_charset_bin);
1481
1475
  }
1482
1476
  else
1483
1477
    field= new Field_double(max_length, maybe_null, name, decimals, true);
1619
1613
  assert(fixed == 1);
1620
1614
  if (null_value)
1621
1615
    return 0.0;
1622
 
 
1623
1616
  switch (hybrid_type) {
1624
1617
  case STRING_RESULT:
1625
 
    {
1626
 
      char *end_not_used;
1627
 
      int err_not_used;
1628
 
      String *res;  res=val_str(&str_value);
1629
 
      return (res ? my_strntod(res->charset(), (char*) res->ptr(), res->length(),
1630
 
                               &end_not_used, &err_not_used) : 0.0);
1631
 
    }
 
1618
  {
 
1619
    char *end_not_used;
 
1620
    int err_not_used;
 
1621
    String *res;  res=val_str(&str_value);
 
1622
    return (res ? my_strntod(res->charset(), (char*) res->ptr(), res->length(),
 
1623
                             &end_not_used, &err_not_used) : 0.0);
 
1624
  }
1632
1625
  case INT_RESULT:
1633
1626
    return (double) sum_int;
1634
1627
  case DECIMAL_RESULT:
1637
1630
  case REAL_RESULT:
1638
1631
    return sum;
1639
1632
  case ROW_RESULT:
 
1633
  default:
1640
1634
    // This case should never be choosen
1641
 
    break;
 
1635
    assert(0);
 
1636
    return 0;
1642
1637
  }
1643
 
 
1644
 
  assert(0);
1645
 
  return 0;
1646
1638
}
1647
1639
 
1648
1640
int64_t Item_sum_hybrid::val_int()
1670
1662
  assert(fixed == 1);
1671
1663
  if (null_value)
1672
1664
    return 0;
1673
 
 
1674
1665
  switch (hybrid_type) {
1675
1666
  case STRING_RESULT:
1676
1667
    string2my_decimal(E_DEC_FATAL_ERROR, &value, val);
1685
1676
    int2my_decimal(E_DEC_FATAL_ERROR, sum_int, unsigned_flag, val);
1686
1677
    break;
1687
1678
  case ROW_RESULT:
 
1679
  default:
1688
1680
    // This case should never be choosen
1689
1681
    assert(0);
1690
1682
    break;
1691
1683
  }
1692
 
 
1693
1684
  return val;                                   // Keep compiler happy
1694
1685
}
1695
1686
 
1700
1691
  assert(fixed == 1);
1701
1692
  if (null_value)
1702
1693
    return 0;
1703
 
 
1704
1694
  switch (hybrid_type) {
1705
1695
  case STRING_RESULT:
1706
1696
    return &value;
1716
1706
  case ROW_RESULT:
1717
1707
  default:
1718
1708
    // This case should never be choosen
 
1709
    assert(0);
1719
1710
    break;
1720
1711
  }
1721
 
 
1722
1712
  return str;                                   // Keep compiler happy
1723
1713
}
1724
1714
 
1756
1746
{
1757
1747
  switch (hybrid_type) {
1758
1748
  case STRING_RESULT:
 
1749
  {
 
1750
    String *result=args[0]->val_str(&tmp_value);
 
1751
    if (!args[0]->null_value &&
 
1752
        (null_value || sortcmp(&value,result,collation.collation) > 0))
1759
1753
    {
1760
 
      String *result=args[0]->val_str(&tmp_value);
1761
 
      if (!args[0]->null_value &&
1762
 
          (null_value || sortcmp(&value,result,collation.collation) > 0))
1763
 
      {
1764
 
        value.copy(*result);
1765
 
        null_value=0;
1766
 
      }
 
1754
      value.copy(*result);
 
1755
      null_value=0;
1767
1756
    }
1768
 
    break;
 
1757
  }
 
1758
  break;
1769
1759
  case INT_RESULT:
 
1760
  {
 
1761
    int64_t nr=args[0]->val_int();
 
1762
    if (!args[0]->null_value && (null_value ||
 
1763
                                 (unsigned_flag &&
 
1764
                                  (uint64_t) nr < (uint64_t) sum_int) ||
 
1765
                                 (!unsigned_flag && nr < sum_int)))
1770
1766
    {
1771
 
      int64_t nr=args[0]->val_int();
1772
 
      if (!args[0]->null_value && (null_value ||
1773
 
                                   (unsigned_flag &&
1774
 
                                    (uint64_t) nr < (uint64_t) sum_int) ||
1775
 
                                   (!unsigned_flag && nr < sum_int)))
1776
 
      {
1777
 
        sum_int=nr;
1778
 
        null_value=0;
1779
 
      }
 
1767
      sum_int=nr;
 
1768
      null_value=0;
1780
1769
    }
1781
 
    break;
 
1770
  }
 
1771
  break;
1782
1772
  case DECIMAL_RESULT:
 
1773
  {
 
1774
    my_decimal value_buff, *val= args[0]->val_decimal(&value_buff);
 
1775
    if (!args[0]->null_value &&
 
1776
        (null_value || (my_decimal_cmp(&sum_dec, val) > 0)))
1783
1777
    {
1784
 
      my_decimal value_buff, *val= args[0]->val_decimal(&value_buff);
1785
 
      if (!args[0]->null_value &&
1786
 
          (null_value || (my_decimal_cmp(&sum_dec, val) > 0)))
1787
 
      {
1788
 
        my_decimal2decimal(val, &sum_dec);
1789
 
        null_value= 0;
1790
 
      }
 
1778
      my_decimal2decimal(val, &sum_dec);
 
1779
      null_value= 0;
1791
1780
    }
1792
 
    break;
 
1781
  }
 
1782
  break;
1793
1783
  case REAL_RESULT:
 
1784
  {
 
1785
    double nr= args[0]->val_real();
 
1786
    if (!args[0]->null_value && (null_value || nr < sum))
1794
1787
    {
1795
 
      double nr= args[0]->val_real();
1796
 
      if (!args[0]->null_value && (null_value || nr < sum))
1797
 
      {
1798
 
        sum=nr;
1799
 
        null_value=0;
1800
 
      }
 
1788
      sum=nr;
 
1789
      null_value=0;
1801
1790
    }
1802
 
    break;
 
1791
  }
 
1792
  break;
1803
1793
  case ROW_RESULT:
 
1794
  default:
1804
1795
    // This case should never be choosen
1805
1796
    assert(0);
1806
1797
    break;
1819
1810
{
1820
1811
  switch (hybrid_type) {
1821
1812
  case STRING_RESULT:
 
1813
  {
 
1814
    String *result=args[0]->val_str(&tmp_value);
 
1815
    if (!args[0]->null_value &&
 
1816
        (null_value || sortcmp(&value,result,collation.collation) < 0))
1822
1817
    {
1823
 
      String *result=args[0]->val_str(&tmp_value);
1824
 
      if (!args[0]->null_value &&
1825
 
          (null_value || sortcmp(&value,result,collation.collation) < 0))
1826
 
      {
1827
 
        value.copy(*result);
1828
 
        null_value=0;
1829
 
      }
 
1818
      value.copy(*result);
 
1819
      null_value=0;
1830
1820
    }
1831
 
    break;
 
1821
  }
 
1822
  break;
1832
1823
  case INT_RESULT:
 
1824
  {
 
1825
    int64_t nr=args[0]->val_int();
 
1826
    if (!args[0]->null_value && (null_value ||
 
1827
                                 (unsigned_flag &&
 
1828
                                  (uint64_t) nr > (uint64_t) sum_int) ||
 
1829
                                 (!unsigned_flag && nr > sum_int)))
1833
1830
    {
1834
 
      int64_t nr=args[0]->val_int();
1835
 
      if (!args[0]->null_value && (null_value ||
1836
 
                                   (unsigned_flag &&
1837
 
                                    (uint64_t) nr > (uint64_t) sum_int) ||
1838
 
                                   (!unsigned_flag && nr > sum_int)))
1839
 
      {
1840
 
        sum_int=nr;
1841
 
        null_value=0;
1842
 
      }
 
1831
      sum_int=nr;
 
1832
      null_value=0;
1843
1833
    }
1844
 
    break;
 
1834
  }
 
1835
  break;
1845
1836
  case DECIMAL_RESULT:
 
1837
  {
 
1838
    my_decimal value_buff, *val= args[0]->val_decimal(&value_buff);
 
1839
    if (!args[0]->null_value &&
 
1840
        (null_value || (my_decimal_cmp(val, &sum_dec) > 0)))
1846
1841
    {
1847
 
      my_decimal value_buff, *val= args[0]->val_decimal(&value_buff);
1848
 
      if (!args[0]->null_value &&
1849
 
          (null_value || (my_decimal_cmp(val, &sum_dec) > 0)))
1850
 
      {
1851
 
        my_decimal2decimal(val, &sum_dec);
1852
 
        null_value= 0;
1853
 
      }
 
1842
      my_decimal2decimal(val, &sum_dec);
 
1843
      null_value= 0;
1854
1844
    }
1855
 
    break;
 
1845
  }
 
1846
  break;
1856
1847
  case REAL_RESULT:
 
1848
  {
 
1849
    double nr= args[0]->val_real();
 
1850
    if (!args[0]->null_value && (null_value || nr > sum))
1857
1851
    {
1858
 
      double nr= args[0]->val_real();
1859
 
      if (!args[0]->null_value && (null_value || nr > sum))
1860
 
      {
1861
 
        sum=nr;
1862
 
        null_value=0;
1863
 
      }
 
1852
      sum=nr;
 
1853
      null_value=0;
1864
1854
    }
1865
 
    break;
 
1855
  }
 
1856
  break;
1866
1857
  case ROW_RESULT:
 
1858
  default:
1867
1859
    // This case should never be choosen
1868
1860
    assert(0);
1869
1861
    break;
1870
1862
  }
1871
 
 
1872
1863
  return 0;
1873
1864
}
1874
1865
 
1956
1947
{
1957
1948
  switch(hybrid_type) {
1958
1949
  case STRING_RESULT:
1959
 
    {
1960
 
      char buff[MAX_FIELD_WIDTH];
1961
 
      String tmp(buff,sizeof(buff),result_field->charset()),*res;
1962
 
 
1963
 
      res=args[0]->val_str(&tmp);
1964
 
      if (args[0]->null_value)
1965
 
      {
 
1950
  {
 
1951
    char buff[MAX_FIELD_WIDTH];
 
1952
    String tmp(buff,sizeof(buff),result_field->charset()),*res;
 
1953
 
 
1954
    res=args[0]->val_str(&tmp);
 
1955
    if (args[0]->null_value)
 
1956
    {
 
1957
      result_field->set_null();
 
1958
      result_field->reset();
 
1959
    }
 
1960
    else
 
1961
    {
 
1962
      result_field->set_notnull();
 
1963
      result_field->store(res->ptr(),res->length(),tmp.charset());
 
1964
    }
 
1965
    break;
 
1966
  }
 
1967
  case INT_RESULT:
 
1968
  {
 
1969
    int64_t nr=args[0]->val_int();
 
1970
 
 
1971
    if (maybe_null)
 
1972
    {
 
1973
      if (args[0]->null_value)
 
1974
      {
 
1975
        nr=0;
 
1976
        result_field->set_null();
 
1977
      }
 
1978
      else
 
1979
        result_field->set_notnull();
 
1980
    }
 
1981
    result_field->store(nr, unsigned_flag);
 
1982
    break;
 
1983
  }
 
1984
  case REAL_RESULT:
 
1985
  {
 
1986
    double nr= args[0]->val_real();
 
1987
 
 
1988
    if (maybe_null)
 
1989
    {
 
1990
      if (args[0]->null_value)
 
1991
      {
 
1992
        nr=0.0;
 
1993
        result_field->set_null();
 
1994
      }
 
1995
      else
 
1996
        result_field->set_notnull();
 
1997
    }
 
1998
    result_field->store(nr);
 
1999
    break;
 
2000
  }
 
2001
  case DECIMAL_RESULT:
 
2002
  {
 
2003
    my_decimal value_buff, *arg_dec= args[0]->val_decimal(&value_buff);
 
2004
 
 
2005
    if (maybe_null)
 
2006
    {
 
2007
      if (args[0]->null_value)
1966
2008
        result_field->set_null();
1967
 
        result_field->reset();
1968
 
      }
1969
2009
      else
1970
 
      {
1971
2010
        result_field->set_notnull();
1972
 
        result_field->store(res->ptr(),res->length(),tmp.charset());
1973
 
      }
1974
 
      break;
1975
 
    }
1976
 
  case INT_RESULT:
1977
 
    {
1978
 
      int64_t nr=args[0]->val_int();
1979
 
 
1980
 
      if (maybe_null)
1981
 
      {
1982
 
        if (args[0]->null_value)
1983
 
        {
1984
 
          nr=0;
1985
 
          result_field->set_null();
1986
 
        }
1987
 
        else
1988
 
          result_field->set_notnull();
1989
 
      }
1990
 
      result_field->store(nr, unsigned_flag);
1991
 
      break;
1992
 
    }
1993
 
  case REAL_RESULT:
1994
 
    {
1995
 
      double nr= args[0]->val_real();
1996
 
 
1997
 
      if (maybe_null)
1998
 
      {
1999
 
        if (args[0]->null_value)
2000
 
        {
2001
 
          nr=0.0;
2002
 
          result_field->set_null();
2003
 
        }
2004
 
        else
2005
 
          result_field->set_notnull();
2006
 
      }
2007
 
      result_field->store(nr);
2008
 
      break;
2009
 
    }
2010
 
  case DECIMAL_RESULT:
2011
 
    {
2012
 
      my_decimal value_buff, *arg_dec= args[0]->val_decimal(&value_buff);
2013
 
 
2014
 
      if (maybe_null)
2015
 
      {
2016
 
        if (args[0]->null_value)
2017
 
          result_field->set_null();
2018
 
        else
2019
 
          result_field->set_notnull();
2020
 
      }
2021
 
      /*
2022
 
        We must store zero in the field as we will use the field value in
2023
 
        add()
2024
 
      */
2025
 
      if (!arg_dec)                               // Null
2026
 
        arg_dec= &decimal_zero;
2027
 
      result_field->store_decimal(arg_dec);
2028
 
      break;
2029
 
    }
 
2011
    }
 
2012
    /*
 
2013
      We must store zero in the field as we will use the field value in
 
2014
      add()
 
2015
    */
 
2016
    if (!arg_dec)                               // Null
 
2017
      arg_dec= &decimal_zero;
 
2018
    result_field->store_decimal(arg_dec);
 
2019
    break;
 
2020
  }
2030
2021
  case ROW_RESULT:
 
2022
  default:
2031
2023
    assert(0);
2032
2024
  }
2033
2025
}
2222
2214
  case DECIMAL_RESULT:
2223
2215
    min_max_update_decimal_field();
2224
2216
    break;
2225
 
  case REAL_RESULT:
2226
 
  case ROW_RESULT:
 
2217
  default:
2227
2218
    min_max_update_real_field();
2228
2219
  }
2229
2220
}
2236
2227
 
2237
2228
  if (!args[0]->null_value)
2238
2229
  {
2239
 
    result_field->val_str_internal(&tmp_value);
 
2230
    result_field->val_str(&tmp_value);
2240
2231
 
2241
2232
    if (result_field->is_null() ||
2242
2233
        (cmp_sign * sortcmp(res_str,&tmp_value,collation.collation)) < 0)
2608
2599
  tmp_table_param->force_copy_fields= force_copy_fields;
2609
2600
  assert(table == 0);
2610
2601
 
2611
 
  if (!(table= create_tmp_table(session, tmp_table_param, list, (Order*) 0, 1,
 
2602
  if (!(table= create_tmp_table(session, tmp_table_param, list, (order_st*) 0, 1,
2612
2603
                                0,
2613
2604
                                (select_lex->options | session->options),
2614
2605
                                HA_POS_ERROR, (char*)"")))
2719
2710
  if (always_null)
2720
2711
    return 0;
2721
2712
  copy_fields(tmp_table_param);
2722
 
  if (copy_funcs(tmp_table_param->items_to_copy, table->in_use))
2723
 
    return true;
 
2713
  copy_funcs(tmp_table_param->items_to_copy);
2724
2714
 
2725
2715
  for (Field **field= table->getFields() ; *field ; field++)
2726
2716
  {
2844
2834
                                    const void* key2)
2845
2835
{
2846
2836
  Item_func_group_concat* grp_item= (Item_func_group_concat*) arg;
2847
 
  Order **order_item, **end;
 
2837
  order_st **order_item, **end;
2848
2838
  Table *table= grp_item->table;
2849
2839
 
2850
2840
  for (order_item= grp_item->order, end=order_item+ grp_item->arg_count_order;
2918
2908
      uint32_t offset= (field->offset(field->getTable()->record[0]) -
2919
2909
                    table->getShare()->null_bytes);
2920
2910
      assert(offset < table->getShare()->getRecordLength());
2921
 
      res= field->val_str_internal(&tmp, key + offset);
 
2911
      res= field->val_str(&tmp, key + offset);
2922
2912
    }
2923
2913
    else
2924
2914
      res= (*arg)->val_str(&tmp);
2988
2978
    order - arg_count_order
2989
2979
  */
2990
2980
  if (!(args= (Item**) memory::sql_alloc(sizeof(Item*) * arg_count +
2991
 
                                 sizeof(Order*)*arg_count_order)))
 
2981
                                 sizeof(order_st*)*arg_count_order)))
2992
2982
    return;
2993
2983
 
2994
 
  order= (Order**)(args + arg_count);
 
2984
  order= (order_st**)(args + arg_count);
2995
2985
 
2996
2986
  /* fill args items of show and sort */
2997
2987
  List_iterator_fast<Item> li(*select_list);
3001
2991
 
3002
2992
  if (arg_count_order)
3003
2993
  {
3004
 
    Order **order_ptr= order;
3005
 
    for (Order *order_item= (Order*) order_list->first;
 
2994
    order_st **order_ptr= order;
 
2995
    for (order_st *order_item= (order_st*) order_list->first;
3006
2996
         order_item != NULL;
3007
2997
         order_item= order_item->next)
3008
2998
    {
3115
3105
  if (always_null)
3116
3106
    return 0;
3117
3107
  copy_fields(tmp_table_param);
3118
 
  if (copy_funcs(tmp_table_param->items_to_copy, table->in_use))
3119
 
    return true;
 
3108
  copy_funcs(tmp_table_param->items_to_copy);
3120
3109
 
3121
3110
  for (uint32_t i= 0; i < arg_count_field; i++)
3122
3111
  {
3270
3259
    field list.
3271
3260
  */
3272
3261
  if (!(table= create_tmp_table(session, tmp_table_param, all_fields,
3273
 
                                (Order*) 0, 0, true,
 
3262
                                (order_st*) 0, 0, true,
3274
3263
                                (select_lex->options | session->options),
3275
3264
                                HA_POS_ERROR, (char*) "")))
3276
3265
  {