Skip to content

Commit

Permalink
fix tests, specif. related to 3e5c7a9
Browse files Browse the repository at this point in the history
  • Loading branch information
Andrei Zavada committed Apr 11, 2016
1 parent 265bc0e commit 3a8a1d7
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 14 deletions.
24 changes: 13 additions & 11 deletions src/riak_kv_qry.erl
Original file line number Diff line number Diff line change
Expand Up @@ -172,9 +172,10 @@ xlate_insert_to_putdata(Values, Positions, Empty) ->
{PutData, [], _} ->
{ok, lists:reverse(PutData)};
{_, Errors, _} ->
{error, io_lib:format(
"too many values in row index(es) ~s",
[string:join(lists:reverse(Errors), ", ")])}
{error, lists:flatten(
io_lib:format(
"too many values in row index(es) ~s",
[string:join(lists:reverse(Errors), ", ")]))}
end.

-spec make_insert_row([] | [riak_ql_ddl:data_value()], [] | [pos_integer()], tuple()) ->
Expand Down Expand Up @@ -300,14 +301,15 @@ describe_table_columns_test() ->
" p double,"
" PRIMARY KEY ((f, s, quantum(t, 15, m)), "
" f, s, t))")),
?assertMatch(
do_describe(DDL),
{ok, {_ColNames, _ColTypes,
[[<<"f">>, <<"varchar">>, false, 1, 1],
[<<"s">>, <<"varchar">>, false, 2, 2],
[<<"t">>, <<"timestamp">>, false, 3, 3],
[<<"w">>, <<"sint64">>, false, undefined, undefined],
[<<"p">>, <<"double">>, true, undefined, undefined]]}}).
{ok, {_ColNames, _CTypes, Rows}} = do_describe(DDL),
?assertEqual(
[[<<"f">>, <<"varchar">>, false, 1, 1],
[<<"s">>, <<"varchar">>, false, 2, 2],
[<<"t">>, <<"timestamp">>, false, 3, 3],
[<<"w">>, <<"sint64">>, false, undefined, undefined],
[<<"p">>, <<"double">>, true, undefined, undefined]],
Rows).

validate_make_insert_row_basic_test() ->
Data = [{integer,4}, {binary,<<"bamboozle">>}, {float, 3.14}],
Positions = [3, 1, 2],
Expand Down
6 changes: 3 additions & 3 deletions src/riak_kv_ts_svc.erl
Original file line number Diff line number Diff line change
Expand Up @@ -643,19 +643,19 @@ validate_rows_bad_2_test() ->
{module, Mod} = test_helper_validate_rows_mod(),
?assertEqual(
["1", "3", "4"],
riak_kv_ts_util:validate_rows(Mod, [{}, {<<"f">>, <<"s">>, 11}, {a, <<"s">>, 12}, "hithere"])
riak_kv_ts_util:validate_rows(Mod, [{}, {<<"f">>, <<"s">>, 11}, {a, <<"s">>, 12}, {"hithere"}])
).

validate_rows_error_response_1_test() ->
Msg = "Invalid data found at row index(es) ",
Msg = "Invalid data at row index(es) ",
?assertEqual(
#rpberrorresp{errcode = ?E_IRREG,
errmsg = Msg ++ "1" },
make_validate_rows_error_resp(["1"])
).

validate_rows_error_response_2_test() ->
Msg = "Invalid data found at row index(es) ",
Msg = "Invalid data at row index(es) ",
?assertEqual(
#rpberrorresp{errcode = ?E_IRREG,
errmsg = Msg ++ "1, 2, 3" },
Expand Down

0 comments on commit 3a8a1d7

Please sign in to comment.