TypeError: connection.query is not a function

produto.js

module.exports = function (app) {
    //DEFININDO ROTA
    app.get('/produtos', function(req, res) {
        //envoca a funcao de conexao com o BD
        var connection = app.infra.connectionFactory();
        var produtosBanco = app.infra.produtosBanco;

        //consulta sql
        produtosBanco.lista(connection,function (err, resultados) {
            //reinderiza json retornado pela consulta
            res.render('produtos/lista', {
                lista: resultados
            });
        });
        //encerra conexao
        connection.end();


    });
}

produtosBanco.js

module.exports = function(){
    this.lista = function(connection,callback){
        connection.query('select * from produtos',callback);
    }
    return this;
}