1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
try:
import numpy as np
import pandas as pd
except ImportError:
np = None
pd = None
from tests.numpy.testcase import NumpyBaseTestCase
class ExternalTablesTestCase(NumpyBaseTestCase):
def test_select(self):
tables = [{
'name': 'test',
'structure': [('x', 'Int32'), ('y', 'String')],
'data': pd.DataFrame({
'x': [100, 500],
'y': ['abc', 'def']
})
}]
rv = self.client.execute(
'SELECT * FROM test', external_tables=tables, columnar=True
)
self.assertArraysListEqual(
rv, [np.array([100, 500]), np.array(['abc', 'def'])]
)
def test_send_empty_table(self):
tables = [{
'name': 'test',
'structure': [('x', 'Int32')],
'data': pd.DataFrame({'x': []})
}]
rv = self.client.execute(
'SELECT * FROM test', external_tables=tables, columnar=True
)
self.assertArraysListEqual(rv, [])
def test_send_empty_table_structure(self):
tables = [{
'name': 'test',
'structure': [],
'data': pd.DataFrame()
}]
with self.assertRaises(ValueError) as e:
self.client.execute(
'SELECT * FROM test', external_tables=tables, columnar=True
)
self.assertIn('Empty table "test" structure', str(e.exception))
|
