init.sql

CREATE UNLOGGED TABLE clientes (
	id SERIAL PRIMARY KEY,
	nome VARCHAR(50) NOT NULL,
	limite INTEGER NOT NULL,
	saldo INTEGER NOT NULL,
	versao INTEGER NOT NULL
);

CREATE UNLOGGED TABLE transacoes (
	id SERIAL PRIMARY KEY,
	cliente_id INTEGER NOT NULL,
	valor INTEGER NOT NULL,
	tipo CHAR(1) NOT NULL,
	descricao VARCHAR(10) NOT NULL,
	realizada_em TIMESTAMP NOT NULL DEFAULT NOW(),
	CONSTRAINT fk_clientes_transacoes_id
		FOREIGN KEY (cliente_id) REFERENCES clientes(id)
);

-- CREATE UNLOGGED TABLE saldos (
-- 	id SERIAL PRIMARY KEY,
-- 	cliente_id INTEGER NOT NULL,
-- 	valor INTEGER NOT NULL,
-- 	CONSTRAINT fk_clientes_saldos_id
-- 		FOREIGN KEY (cliente_id) REFERENCES clientes(id)
-- );

DO $$
BEGIN
INSERT INTO clientes (nome, limite, saldo, versao)
VALUES
    ('o barato sai caro', 1000 * 100, 0, 0),
    ('zan corp ltda', 800 * 100, 0, 0),
    ('les cruders', 10000 * 100, 0, 0),
    ('padaria joia de cocaia', 100000 * 100, 0, 0),
    ('kid mais', 5000 * 100, 0, 0);

-- INSERT INTO saldos (cliente_id, valor)
-- SELECT id, 0 FROM clientes;
END;
$$;

-- CREATE OR REPLACE FUNCTION debitar(
-- 	cliente_id_tx INT,
-- 	valor_tx INT,
-- 	descricao_tx VARCHAR(10))
-- RETURNS TABLE (
-- 	novo_saldo INT,
-- 	possui_erro BOOL,
-- 	mensagem VARCHAR(20))
-- LANGUAGE plpgsql
-- AS $$
-- DECLARE
-- saldo_atual int;
-- 	limite_atual int;
-- BEGIN
-- 	PERFORM pg_advisory_xact_lock(cliente_id_tx);
-- SELECT
--     c.limite,
--     COALESCE(s.valor, 0)
-- INTO
--     limite_atual,
--     saldo_atual
-- FROM clientes c
--          LEFT JOIN saldos s
--                    ON c.id = s.cliente_id
-- WHERE c.id = cliente_id_tx;
--
-- IF saldo_atual - valor_tx >= limite_atual * -1 THEN
-- 		INSERT INTO transacoes
-- 			VALUES(DEFAULT, cliente_id_tx, valor_tx, 'd', descricao_tx, NOW());
--
-- UPDATE saldos
-- SET valor = valor - valor_tx
-- WHERE cliente_id = cliente_id_tx;
--
-- RETURN QUERY
-- SELECT
--     valor,
--     FALSE,
--     'ok'::VARCHAR(20)
-- FROM saldos
-- WHERE cliente_id = cliente_id_tx;
-- ELSE
-- 		RETURN QUERY
-- SELECT
--     valor,
--     TRUE,
--     'saldo insuficente'::VARCHAR(20)
-- FROM saldos
-- WHERE cliente_id = cliente_id_tx;
-- END IF;
-- END;
-- $$;
--
-- CREATE OR REPLACE FUNCTION creditar(
-- 	cliente_id_tx INT,
-- 	valor_tx INT,
-- 	descricao_tx VARCHAR(10))
-- RETURNS TABLE (
-- 	novo_saldo INT,
-- 	possui_erro BOOL,
-- 	mensagem VARCHAR(20))
-- LANGUAGE plpgsql
-- AS $$
-- BEGIN
-- 	PERFORM pg_advisory_xact_lock(cliente_id_tx);
--
-- INSERT INTO transacoes
-- VALUES(DEFAULT, cliente_id_tx, valor_tx, 'c', descricao_tx, NOW());
--
-- RETURN QUERY
-- UPDATE saldos
-- SET valor = valor + valor_tx
-- WHERE cliente_id = cliente_id_tx
--     RETURNING valor, FALSE, 'ok'::VARCHAR(20);
-- END;
-- $$;