Added test for creating a table with a local index.
This commit is contained in:
parent
9400cc3ba4
commit
582db74dee
@ -11,8 +11,9 @@ from moto import mock_dynamodb2
|
|||||||
from boto.exception import JSONResponseError
|
from boto.exception import JSONResponseError
|
||||||
from tests.helpers import requires_boto_gte
|
from tests.helpers import requires_boto_gte
|
||||||
try:
|
try:
|
||||||
from boto.dynamodb2.fields import GlobalAllIndex, HashKey, RangeKey
|
from boto.dynamodb2.fields import GlobalAllIndex, HashKey, RangeKey, AllIndex
|
||||||
from boto.dynamodb2.table import Item, Table
|
from boto.dynamodb2.table import Item, Table
|
||||||
|
from boto.dynamodb2.types import STRING
|
||||||
from boto.dynamodb2.exceptions import ValidationException
|
from boto.dynamodb2.exceptions import ValidationException
|
||||||
from boto.dynamodb2.exceptions import ConditionalCheckFailedException
|
from boto.dynamodb2.exceptions import ConditionalCheckFailedException
|
||||||
except ImportError:
|
except ImportError:
|
||||||
@ -30,6 +31,30 @@ def create_table():
|
|||||||
return table
|
return table
|
||||||
|
|
||||||
|
|
||||||
|
def create_table_with_local_indexes():
|
||||||
|
table = Table.create(
|
||||||
|
'messages',
|
||||||
|
schema=[
|
||||||
|
HashKey('forum_name'),
|
||||||
|
RangeKey('subject'),
|
||||||
|
],
|
||||||
|
throughput={
|
||||||
|
'read': 10,
|
||||||
|
'write': 10,
|
||||||
|
},
|
||||||
|
indexes=[
|
||||||
|
AllIndex(
|
||||||
|
'recipient_timestamp_index',
|
||||||
|
parts=[
|
||||||
|
HashKey('forum_name', data_type=STRING),
|
||||||
|
RangeKey('timestamp'),
|
||||||
|
]
|
||||||
|
)
|
||||||
|
]
|
||||||
|
)
|
||||||
|
return table
|
||||||
|
|
||||||
|
|
||||||
def iterate_results(res):
|
def iterate_results(res):
|
||||||
for i in res:
|
for i in res:
|
||||||
pass
|
pass
|
||||||
@ -63,6 +88,48 @@ def test_create_table():
|
|||||||
table.describe().should.equal(expected)
|
table.describe().should.equal(expected)
|
||||||
|
|
||||||
|
|
||||||
|
@requires_boto_gte("2.9")
|
||||||
|
@mock_dynamodb2
|
||||||
|
@freeze_time("2012-01-14")
|
||||||
|
def test_create_table():
|
||||||
|
table = create_table_with_local_indexes()
|
||||||
|
expected = {
|
||||||
|
'Table': {
|
||||||
|
'AttributeDefinitions': [
|
||||||
|
{'AttributeName': 'forum_name', 'AttributeType': 'S'},
|
||||||
|
{'AttributeName': 'subject', 'AttributeType': 'S'},
|
||||||
|
{'AttributeName': 'timestamp', 'AttributeType': 'S'}
|
||||||
|
],
|
||||||
|
'ProvisionedThroughput': {
|
||||||
|
'NumberOfDecreasesToday': 0,
|
||||||
|
'WriteCapacityUnits': 10,
|
||||||
|
'ReadCapacityUnits': 10,
|
||||||
|
},
|
||||||
|
'TableSizeBytes': 0,
|
||||||
|
'TableName': 'messages',
|
||||||
|
'TableStatus': 'ACTIVE',
|
||||||
|
'KeySchema': [
|
||||||
|
{'KeyType': 'HASH', 'AttributeName': 'forum_name'},
|
||||||
|
{'KeyType': 'RANGE', 'AttributeName': 'subject'}
|
||||||
|
],
|
||||||
|
'LocalSecondaryIndexes': [
|
||||||
|
{
|
||||||
|
'IndexName': 'recipient_timestamp_index',
|
||||||
|
'KeySchema': [
|
||||||
|
{'AttributeName': 'forum_name', 'KeyType': 'HASH'},
|
||||||
|
{'AttributeName': 'timestamp', 'KeyType': 'RANGE'}
|
||||||
|
],
|
||||||
|
'Projection': {'ProjectionType': 'ALL'}
|
||||||
|
}
|
||||||
|
],
|
||||||
|
'ItemCount': 0,
|
||||||
|
'CreationDateTime': 1326499200.0,
|
||||||
|
'GlobalSecondaryIndexes': [],
|
||||||
|
}
|
||||||
|
}
|
||||||
|
table.describe().should.equal(expected)
|
||||||
|
|
||||||
|
|
||||||
@requires_boto_gte("2.9")
|
@requires_boto_gte("2.9")
|
||||||
@mock_dynamodb2
|
@mock_dynamodb2
|
||||||
def test_delete_table():
|
def test_delete_table():
|
||||||
|
Loading…
x
Reference in New Issue
Block a user