• Home

  • Custom Ecommerce
  • Application Development
  • Database Consulting
  • Cloud Hosting
  • Systems Integration
  • Legacy Business Systems
  • Security & Compliance
  • GIS

  • Expertise

  • About Us
  • Our Team
  • Clients
  • Blog
  • Careers

  • CasePointer

  • VisionPort

  • Contact
  • Our Blog

    Ongoing observations by End Point Dev people

    Testing user-defined functions with pgTAP

    Todor “Theo” Dimov

    By Todor “Theo” Dimov
    September 25, 2023

    An overhead shot of a market full of thousands of colorful DVD cases. Several people peruse the wares in an aisle

    For a great introduction to the pgTAP protocol, please read over my colleague Josh Tolley’s article, using pgTAP to automate database testing. Also check out Edgar Mlowe’s article on how to set up pgTAP for writing PostgreSQL database unit tests.

    As a protocol, pgTAP provides a great list of functions and commands to easily and clearly test all aspects of a database. As I’ve been tasked with more implementations of unit tests for user-defined functions, I thought it helpful to share some useful methods.

    First we’ll go over a few basic pgTAP functions that are useful in testing the existence of functions and procedures. Then we’ll use the PostgreSQL port of the Sakila sample database for MySQL, called Pagila. We’ll construct two functions and go over a single test case. Using basic Postgres tools, I’ll walk through a few methods of calling and testing our functions. Finally, we’ll go over a more concise way of testing all cases for said functions.

    Feel free to work alongside this article to hopefully leave with a comfortable idea of how to construct unit test files for your database.

    Functions:

    For this first example, remember to have the pgTAP extension in your schema and to perform it in a transaction (I’ve omitted BEGIN and ROLLBACK for brevity). Also use SELECT plan(<number of tests you’ll run>) when running the pgTAP functions.

    Starting off, let’s create a basic addition function that returns an integer value:

    CREATE OR REPLACE FUNCTION add_numbers(
        num1 integer,
        num2 integer
    )
    RETURNS integer
    LANGUAGE plpgsql AS $$
    BEGIN
        RETURN num1 + num2;
    END;
    $$;
    

    To test this user-defined function, a few of the most relevant functions in pgTAP we can use are:

    has_function()

    Variations:

    SELECT has_function( :schema, :function, :args, :description );
    SELECT has_function( :schema, :function, :args );
    SELECT has_function( :schema, :function, :description );
    SELECT has_function( :schema, :function );
    SELECT has_function( :function, :args, :description );
    SELECT has_function( :function, :args );
    SELECT has_function( :function, :description );
    SELECT has_function( :function );
    

    Parameters:

    :schema
        Name of a schema in which to find the function.
    :function
        Name of a function.
    :args
        Array of data types of the function arguments.
    :description
        A short description of the test.
    

    Example:

    SELECT has_function('your_schema', 'add_numbers', ARRAY['integer','integer']); -- default description used
    

    Results:

    ok 1 - Function add_numbers(integer, integer) should exist
    

    has_function() is useful in checking the existence of a specific function. If you want to parse an entire schema, functions_are() is your command.

    functions_are()

    Variations:

    SELECT functions_are( :schema, :functions, :description );
    SELECT functions_are( :schema, :functions );
    SELECT functions_are( :functions, :description );
    SELECT functions_are( :functions );
    

    Parameters:

    :schema
        Name of a schema in which to find functions.
    :functions
        An array of function names.
    :description
        A short description of the test.
    

    Example:

    SELECT functions_are('your_schema', ARRAY['add_numbers', <All other functions need to be listed as well>]); -- default description used
    

    ok() and is()

    ok() and is() have similar functionality with slightly different parameters:

    SELECT ok( :boolean, :description );
    

    Example:

    SELECT ok(add_numbers(5,5)=10, 'add_numbers correctly works');
    

    Parameters:

    :boolean
        A boolean value indicating success or failure.
    :description
        A short description of the test.
    

    While ok() is used for passing a test returning a boolean, is() takes two values to compare:

    SELECT is( :have, :want, :description );
    

    Example:

    SELECT is(add_numbers(5,5), 10, 'add_numbers correctly works');
    

    You can find functions that cover pretty much anything in PostgreSQL here in pgTAP’s documentation.

    Testing more complex user-defined stored functions:

    A client product we created utilizes a function that calls several other functions depending on its given argument. This function is called by the application and is passed an integer as an argument from which the function bases an initial SELECT query’s WHERE condition on, in this case WHERE id = [argument]. Variables are then assigned column values from this queried table. These variables are then used as the conditions to PERFORM functions that change parts of the database.

    When testing this sort of scenario, it became apparent that we needed a set of test data, as well as the ability to track that test data, run the function with the data, and test to see if the changes are performed correctly.

    The nice thing about pgTAP is that unit tests are meant to be rolled back leaving the database as you found it. When faced with a more complex function that nests other functions which loop through multiple tables, it may make more sense to fill those tables temporarily with the data required for the tests.

    Let’s take a nostalgia trip and imagine we’re operating a DVD rental store. The Pagila sample database, which you can download on GitHub, represents our scenario. It comes populated and we’ll construct a function which utilizes other functions to perform changes on multiple tables.

    Say the DVD rental shop gives extensions of rentals for special occasions, one being that a DVD was rented on Christmas week. Suppose we have an initial function that checks if a new DVD is rented on one of these special occasions. It then calls another function that will extend the return date, based on the specific occasion:

    CREATE OR REPLACE FUNCTION extension_check(_rental_id integer)
        RETURNS void
        LANGUAGE plpgsql
    AS $function$
    DECLARE
        _rental_date date;
        _inventory_id integer;
        _customer_id integer;
        _return_date date;
        christmas_week date;
    BEGIN
    
        SELECT INTO _rental_date
        rental_date FROM rental
        WHERE rental_id = _rental_id;
    
        IF EXTRACT(YEAR FROM _rental_date) = EXTRACT(YEAR FROM CURRENT_DATE) AND
           _rental_date <= (EXTRACT(YEAR FROM CURRENT_DATE)::text || '-12-25')::date AND
           _rental_date >  (EXTRACT(YEAR FROM CURRENT_DATE)::text || '-12-25')::date - INTERVAL '7 days' THEN
            PERFORM christmas_extension(_rental_id);
        END IF;
    END;
    $function$;
    
    CREATE OR REPLACE FUNCTION christmas_extension(_rental_id integer)
        RETURNS void
        LANGUAGE plpgsql
    AS $function$
    DECLARE
        _rental_date date;
        _return_date date;
    BEGIN
        SELECT return_date FROM rental WHERE rental_id = _rental_id INTO _return_date;
    
        IF _return_date IS NULL THEN
            UPDATE rental SET return_date = rental_date + INTERVAL '10 days' WHERE rental_id=_rental_id;
        ELSE
            UPDATE rental SET return_date = return_date + INTERVAL '10 days' WHERE rental_id=_rental_id;
        END IF;
    END;
    $function$;
    

    The initial function, extension_check, simply checks if the rental was checked out on the week prior to and on Christmas (It’s a really dedicated DVD shop). We can also assume a function like this has other scenarios where it would extend rental dates but we’ll just show one for this exercise; christmas_extension is our one extension function that extends the return date by ten days.

    To hold our unit test, we’ll create a file fittingly named extension_unit_tests.sql. A problem with the current sample database is that we can’t really test out the function directly since the dates don’t extend to the current year. Rather even if they did, we don’t want to directly affect the existing data especially if the dates were updated and the database was in production use.

    Relatively basic but handy Postgres tools let us create test cases which we can pass to the functions. Afterwards, we can use pgTAP functions to confirm that our user-defined functions extension_check and christmas_extension worked properly.

    For test cases in our new file, extension_unit_tests.sql, we’ll need a way to create and track them. For this, we’ll use a temporary table to track the test IDs and a PROCEDURE which can be called at any point to create the test cases. After that, we’ll simply call the procedure and run the user-defined function extension_check. Finally test its existence, test its result, and roll back our changes.

    BEGIN;
    
    CREATE TEMPORARY TABLE test_instance_references (
        test_rental_id integer PRIMARY KEY,
        test_number integer
    );
    
    CREATE OR REPLACE PROCEDURE fill_test_data (
        _rental_date date,
        _test_number integer
    )
    LANGUAGE PLPGSQL
    AS $procedure$
    DECLARE
        _address_id integer;
        _store_id integer;
        _staff_id integer;
        _inventory_id integer;
        _customer_id integer;
        _rental_id integer;
    BEGIN
    
        SELECT nextval('customer_customer_id_seq1'::regclass) INTO _customer_id;
        SELECT nextval('rental_rental_id_seq'::regclass) INTO _rental_id;
        SELECT nextval('inventory_inventory_id_seq'::regclass) INTO _inventory_id;
        SELECT store_id FROM store LIMIT 1 INTO _store_id; -- any store will do
        SELECT address_id FROM address LIMIT 1 INTO _address_id; -- any address will do
    
        INSERT INTO customer (customer_id, store_id, first_name, last_name, address_id)
        VALUES (
            _customer_id,
            _store_id,
            'Test First Name',
            'Test Last Name',
            _address_id
        );
    
        INSERT INTO inventory (inventory_id, film_id, store_id)
        VALUES (
            _inventory_id,
            (SELECT film_id FROM film LIMIT 1), -- arbitrary film
            _store_id
        );
    
        INSERT INTO rental (rental_id, rental_date, inventory_id, customer_id, staff_id)
        VALUES (
            _rental_id,
            _rental_date,
            _inventory_id,
            _customer_id,
            (SELECT staff_id FROM staff WHERE store_id = _store_id LIMIT 1) -- select arbitrary staff member from store
        );
    
        INSERT INTO test_instance_references (test_rental_id, test_number)
        values (
            _rental_id,
            _test_number
        );
    
    END;
    $procedure$;
    
    CALL fill_test_data('2023-12-25'::date, 1); -- Fill the db with our test data
    
    SELECT extension_check((SELECT test_rental_id FROM test_instance_references WHERE test_number = 1)); -- Call our user-defined function
    
    SELECT plan(2); -- State the number of tests we'll be performing
    
    SELECT has_function(
        'extension_check',
        ARRAY['int']
    );
    
    SELECT is(
        (SELECT return_date FROM rental WHERE rental_id in (SELECT test_rental_id FROM test_instance_references WHERE test_number = 1))::date,
        ('2023-12-25'::date + INTERVAL '10 DAYS')::date,
        'Checking test data 1, week of Christmas'
    );
    
    
    ROLLBACK;
    

    By design, pgTAP tests are performed in a transaction block with a ROLLBACK at the end to reverse all changes. Our first transaction is the creation of a temporary table called test_instance_references which will hold the IDs of the sample data we insert specifically in the rental table. This way we keep track of our specific test cases through their primary identifier.

    Our PROCEDURE works similarly to a function, but where a function may have issues being called in a transaction block through pgTAP’s command line pg_prove, the use of a procedure and its CALL command is far more reliable.

    In our example, the procedure simply adds in all the required test data. Note the insertion of test data into other tables that are referenced in rental, as well as an insert into the temporary table for tracking. To avoid using any existing data in the database, references are also test samples, like for the customer. Some, however, are selected from existing tables. It’s important to make sure you’re not affecting real data in the database in case a transaction fails. The example is obviously lax when it comes to that, specifically with the references to store and address, so please take note in your own unit tests to be careful when referring to existing data.

    After we’ve established our procedure, we’re ready to run the tests. The pgTAP function plan() defines how many unit tests we are going to run. For the first example we run two tests.

    Before running tests, we call the procedure fill_test_data which populates the database with test data and the temporary table to track that data.

    Our first test is to check if the function exists. pgTAP’s has_function function is perfect for this.

    Our procedure is then called with a date for the test rental. This test rental’s ID is saved into the temporary test_instance_references table which is then passed to the main function we want to test, extension_check. We call this function with the SELECT command, and immediately test the outcome with pgTAP’s is(). Our :have parameter holds the return_date of our test rental which is tested to see if it’s been correctly extended by 10 days. Our final parameter is the description which will be returned in the outcome of pg_prove if the test fails.

    The ROLLBACK is meant to clean the database of all test data.

    Let’s run this unit test on the command line, with pg_prove:

    pg_prove -d <your_database> <path_to_your_unit_test>/extension_unit_tests.sql
    

    We should see these results:

    extension_unit_tests.sql .. ok
    All tests successful.
    Files=1, Tests=2,  0 wallclock secs ( 0.01 usr +  0.00 sys =  0.01 CPU)
    Result: PASS
    

    Congrats! We’ve tested out a single case for a function.

    However, what if we want to test all possible cases for this function to be sure it performs correctly?

    To do this, we can alter the procedure fill_test_data to loop through a date range given in the arguments _start_date and _end_date. For our example we’ll provide it with the week of Christmas, but it’ll work for any date range provided the rental store gives extensions for DVDs rented on other dates.

    Instead of passing a test number as an argument, we can simply initialize it as a variable that’s incremented with every loop. Inside the WHILE loop, every iteration will populate the database with the test data, perform extension_check with the test rental ID, and increment the date and test number.

    We’ll end the transaction a little differently by setting our pgTAP plan equal to the number of tests we have in our temporary table, to avoid hard-coding our plan count. We’ll also add one to check its existence with has_function.

    Finally, our is() will also iterate through our temporary table and perform a check in the rental table to confirm that the return date has been correctly extended by ten days.

    BEGIN;
    
    CREATE TEMPORARY TABLE test_instance_references (
        test_rental_id integer PRIMARY KEY,
        test_number integer,
        start_date date
    );
    
    
    CREATE OR REPLACE PROCEDURE fill_test_data (
            _start_date date,
            _end_date date
        )
        LANGUAGE PLPGSQL
        AS $procedure$
        DECLARE
            _address_id smallint;
            _store_id smallint;
            _inventory_id integer;
            _customer_id integer;
            _rental_id integer;
            _test_number integer;
        BEGIN
            _test_number := 1;
    
            WHILE _start_date <= _end_date LOOP
                SELECT nextval('customer_customer_id_seq1'::regclass) INTO _customer_id;
                SELECT nextval('rental_rental_id_seq'::regclass) INTO _rental_id;
                SELECT nextval('inventory_inventory_id_seq'::regclass) INTO _inventory_id;
                SELECT store_id FROM store LIMIT 1 INTO _store_id; -- any store will do
                SELECT address_id FROM address LIMIT 1 INTO _address_id; -- any address will do
    
                INSERT INTO customer (customer_id, store_id, first_name, last_name, address_id)
                VALUES (
                    _customer_id,
                    _store_id,
                    'Test First Name',
                    'Test Last Name',
                    _address_id
                );
    
                INSERT INTO inventory (inventory_id, film_id, store_id)
                VALUES (
                    _inventory_id,
                    (SELECT film_id FROM film LIMIT 1), -- arbitrary film
                    _store_id
                );
    
                INSERT INTO rental (rental_id, rental_date, inventory_id, customer_id, staff_id)
                VALUES (
                    _rental_id,
                    _start_date,
                    _inventory_id,
                    _customer_id::smallint,
                    (SELECT staff_id FROM staff WHERE store_id = _store_id LIMIT 1) -- select arbitrary staff member from store
                );
    
                INSERT INTO test_instance_references (test_rental_id, test_number, start_date)
                VALUES (
                    _rental_id,
                    _test_number,
                    _start_date
                );
    
                PERFORM extension_check(_rental_id);
    
                _start_date := _start_date + INTERVAL '1 day';
                _test_number := _test_number + 1;
    
            END LOOP;
        END;
    $procedure$;
    
    CALL fill_test_data(('2023-12-25'::date - INTERVAL '6 days')::date, '2023-12-25'::date);
    
    SELECT plan(count(*)::integer + 1) from test_instance_references;
    
    SELECT * from test_instance_references;
    
    SELECT has_function(
        'extension_check',
        ARRAY['int']
        -- Description optional - default description usually substantial
    );
    
    SELECT is(
        (SELECT return_date FROM rental WHERE rental_id = tf.test_rental_id)::date,
        (tf.start_date + INTERVAL '10 DAYS')::date
    )
    FROM test_instance_references as tf;
    
    
    ROLLBACK;
    

    Our results should be:

    $ pg_prove -d <your_database> <path_to_your_unit_test>/extension_unit_tests.sql
    extension_unit_tests.sql .. ok
    All tests successful.
    Files=1, Tests=8,  0 wallclock secs ( 0.02 usr +  0.00 sys =  0.02 CPU)
    Result: PASS
    

    As someone who found pgTAP fairly straightforward the challenge of intertwining those functions in a repeatable way was what drove me to write this article. Hopefully this makes it easier for the next coder to play around and get the most out of this simple but intuitive “Test Anything Protocol”.

    Feel free to share your thoughts and comments below, or to share any more useful tips on pgTAP or general Postgres unit testing.

    sql postgres database testing


    Comments