PolarDB:Fungsi yang Didefinisikan Pengguna

Pushdown fungsi

PolarDB-X memeriksa bidang SQL DATA ACCESS dari sebuah UDF untuk menentukan apakah akan mendaftarkannya pada node data. Hanya UDF dengan nilai SQL DATA ACCESS yang diatur ke NO SQL yang didaftarkan pada node data dan dapat dipushdown.

Untuk menjaga kompatibilitas MySQL, PolarDB-X mendaftarkan UDF yang memenuhi syarat pushdown ke pustaka MySQL pada node data.

Bidang SQL DATA ACCESS tidak dapat diubah karena melibatkan logika pushdown UDF.

Pushdown setelah penskalaan

Setelah penskalaan, jalankan pushdown udf untuk mendaftarkan UDF yang memenuhi syarat pushdown ke node data (DN) baru.

Membuat UDF

CREATE
    [DEFINER = user]
    FUNCTION sp_name ([func_parameter[,...]])
    RETURNS type
    [characteristic ...] routine_body

func_parameter:
    param_name type

characteristic:
    COMMENT 'string'
  | LANGUAGE SQL
  | [NOT] DETERMINISTIC
  | { CONTAINS SQL | NO SQL | READS SQL DATA | MODIFIES SQL DATA }
  | SQL SECURITY { DEFINER | INVOKER }

routine_body:
    Valid SQL routine statement

Karakteristik utama:

Contoh:

CREATE FUNCTION my_mul(x int, y int)
RETURNS int
LANGUAGE SQL
DETERMINISTIC
COMMENT 'my multiply function'
RETURN x*y*31;

Memanggil UDF

Panggil UDF dengan cara yang sama seperti fungsi bawaan:

SELECT my_mul(2, 2);
+--------------+
| my_mul(2, 2) |
+--------------+
|          124 |
+--------------+

Memodifikasi UDF

ALTER FUNCTION mendukung modifikasi COMMENT, LANGUAGE SQL, dan SQL SECURITY. Perintah ini tidak mendukung perubahan pada SQL DATA ACCESS.

ALTER FUNCTION func_name [characteristic ...]

characteristic: {
    COMMENT 'string'
  | LANGUAGE SQL
  | SQL SECURITY { DEFINER | INVOKER }
}

Menghapus UDF

DROP FUNCTION [IF EXISTS] FUNCTION_NAME;

Menampilkan UDF

Menampilkan semua UDF:

SELECT * FROM information_schema.Routines WHERE ROUTINE_TYPE = 'FUNCTION';

Menampilkan UDF tertentu:

SHOW FUNCTION STATUS [LIKE 'pattern' | WHERE expr]

SHOW CREATE FUNCTION function_name;

SELECT * FROM information_schema.Routines WHERE ROUTINE_NAME = 'function_name';

Lihat UDF yang didorong ke bawah:

SELECT * FROM information_schema.pushed_function;

Membatalkan UDF yang sedang berjalan

Jalankan pernyataan KILL untuk menghentikan kueri yang sedang mengeksekusi UDF:

KILL {QUERY | CONNECTION} connection_id;

Perintah cache

Contoh siklus hidup cache

Contoh berikut menjelaskan seluruh siklus hidup cache untuk my_mul.

-- Membuat UDF.
CREATE FUNCTION my_mul(x int, y int)
     RETURNS int
     LANGUAGE SQL
     DETERMINISTIC
     COMMENT 'my multiply function'
     RETURN x*y*31;

-- Fungsi ada dalam cache, tetapi badan fungsi belum dimuat (SIZE = 0).
SELECT * FROM information_schema.function_cache;
+--------------------+--------------+------+
| ID                 | FUNCTION     | SIZE |
+--------------------+--------------+------+
| xx.xx.xx.xx:3000   | mysql.my_mul |    0 |
| yy.yy.yy.yy:3100   | mysql.my_mul |    0 |
+--------------------+--------------+------+

-- Memanggil UDF. Ini memicu pemuatan badan fungsi pada satu node.
SELECT my_mul(2, 2);
+--------------+
| my_mul(2, 2) |
+--------------+
|          124 |
+--------------+

-- Badan fungsi kini dimuat pada node yang mengeksekusi panggilan (SIZE = 79).
SELECT * FROM information_schema.function_cache;
+--------------------+--------------+------+
| ID                 | FUNCTION     | SIZE |
+--------------------+--------------+------+
| xx.xx.xx.xx:3000   | mysql.my_mul |    0 |
| yy.yy.yy.yy:3100   | mysql.my_mul |   79 |
+--------------------+--------------+------+

SELECT * FROM information_schema.function_cache_capacity;
+--------------------+-----------+-------------+
| ID                 | USED_SIZE | TOTAL_SIZE  |
+--------------------+-----------+-------------+
| xx.xx.xx.xx:3000   |         0 | 15139759718 |
| yy.yy.yy.yy:3100   |        79 | 15139759718 |
+--------------------+-----------+-------------+

-- Memuat ulang UDF untuk mengatur ulang cache di semua node.
RELOAD FUNCTIONS;

-- Semua node kembali menunjukkan SIZE = 0.
SELECT * FROM information_schema.function_cache;
+--------------------+--------------+------+
| ID                 | FUNCTION     | SIZE |
+--------------------+--------------+------+
| xx.xx.xx.xx:3000   | mysql.my_mul |    0 |
| yy.yy.yy.yy:3100   | mysql.my_mul |    0 |
+--------------------+--------------+------+

Batas memori

Selama eksekusi UDF, memori terutama digunakan oleh kursor. Gunakan parameter berikut untuk mengatur batas memori:

Memori untuk seluruh kueri yang memanggil UDF juga dibatasi.

Batas kedalaman pemanggilan

Gunakan parameter MAX_PL_DEPTH untuk membatasi kedalaman pemanggilan UDF. Tumpukan panggilan yang dalam sulit di-debug dan mengonsumsi sumber daya signifikan.