Author: Eric Lendvai     

Eric Lendvai

×

Bio
Full Stack Web and Desktop App Developer with 30+ years of experience in designing and developing medium to large applications in multiple computer languages.

Website
https://www.linkedin.com/in/ericlendvai/

Country
United States of America

Languages
English, French, Hungarian

Done

CREATE OR REPLACE FUNCTION GetPythonVersion() RETURNS textAS $$import sysreturn sys.version$$ LANGUAGE plpython3u;

DO $$DECLARE    v_cVersion Text;BEGIN    SELECT GetPythonVersion() INTO v_cVersion;    RAISE NOTICE 'Python Version = %',v_cVersion;END; $$

CREATE OR REPLACE FUNCTION pythonmax (a integer, b integer) RETURNS integerAS $$    if (a is None) or (b is None):        return None    if a > b:        return a    return b$$ LANGUAGE plpython3u;

DO $$DECLARE    v_iMaxValue integer;BEGIN    SELECT pythonmax(2,5) INTO v_iMaxValue;    RAISE NOTICE 'Python Max of 2 and 5 is %',v_iMaxValue;END; $$

CREATE OR REPLACE FUNCTION SendMessage (par_message text)    RETURNS textAS $$    import socket    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)    address = ('127.0.0.1', 49152)    sock.sendto(bytes(par_message, 'utf-8'), address)    sock.close()    return par_message$$ LANGUAGE plpython3u;

SELECT SendMessage('hello');

DO $$BEGIN    PERFORM SendMessage('hello');END; $$

import socketfrom datetime import datetimedef main():    UDP_IP = "127.0.0.1"    UDP_PORT = 49152    nCounter = 0    sock = socket.socket(socket.AF_INET, # Internet                        socket.SOCK_DGRAM) # UDP    sock.bind((UDP_IP, UDP_PORT))    while True:        try:            nCounter += 1            data, addr = sock.recvfrom(1024*1024) # buffer size is 1Mb            dt = datetime.now()            print("{0:05d}|{1}|{2}".format(nCounter,dt,data.decode("utf-8")) )        except:            print("Overflow")if __name__ == "__main__":    main()

CREATE TABLE product(    pk integer NOT NULL GENERATED ALWAYS AS IDENTITY ( INCREMENT 1 START 1),    name text,    CONSTRAINT product_pkey PRIMARY KEY (pk))

CREATE OR REPLACE PROCEDURE AddManyProducts()LANGUAGE plpython3uAS $$for i in range(1, 11):    plpy.execute("INSERT INTO product (name) VALUES ('Thing {}')".format(i))$$;CALL AddManyProducts();

DO $$    # PL/Python code    from datetime import datetime    cCurrentTime = datetime.now().strftime("%H:%M:%S")    plpy.execute("INSERT INTO product (name) VALUES ('Thing {}')".format(cCurrentTime))    plpy.execute("SELECT SendMessage('Added a record in product table at {}')".format(cCurrentTime))$$ LANGUAGE plpython3u;