标签: functions

我在 postgres 中有一个包含 147 个表的数据库；这些表包含由具有系统大部分逻辑的函数生成的数据，例如如何构建会计分录。

这些函数由java中的应用程序调用，该应用程序在代码中几乎没有业务逻辑。

此数据库结构用于不同的客户，其中一些功能对每个客户进行了小的调整，并在功能体中进行了注释。

1. 大多数逻辑都在数据库中的这种方法是否正确？

2. 如果您更新数据库中的一个函数并且我们必须将其传递给彼此，我们如何轻松区分哪个函数发生了更改？不要通过错误删除或替换客户端数据库中的更改？

我在 Visual Studio 2013 中有一个带有以下签名的 SQLCLR 存储过程：

[SqlFunction(DataAccess = DataAccessKind.Read, SystemDataAccess = SystemDataAccessKind.Read)]
public static SqlString ExecSql2Json(SqlString sql)

或者我已经尝试过：

[SqlFunction(DataAccess = DataAccessKind.Read, SystemDataAccess = SystemDataAccessKind.Read)]
public static SqlChar ExecSql2Json(SqlChar sql)

无论哪种方式，参数和返回类型都被定义为NVARCHAR(4000). 我希望他们成为NVARCHAR(MAX)。

我知道我可以手动编写自己的CREATE PROCEDURE语句来进行细粒度控制。是否有任何选项可以更改 SQL Server 生成的部署 DDL，或者我是否只需要手动添加脚本来删除和读取具有正确签名的 UDF？

我有一个功能：

merge_vehicles(vid, cid, vname, reg_no, name, name_1st)

我可以在输入上多次调用它吗

(2335, 55, '246BDH', '246BDH', '811', 1),
(2336, 55, '038THX', '038THX', '831', 1),
....

该函数是一个UPSERT实现返回void. 这是一个仓库数据库（事实表）。我们有一个实时数据库，每小时可以获取 1000 多个输入。我们想使用此命令将我们的数据与新数据合并。

它是一个表函数。（我已经为我们拥有的每个表定义了类似的函数 - 即 5。）结果是，它将更新现有行（如果存在），否则插入新行。

Postgres 版本是 9.3。

函数是此处接受的答案的一个版本：

• 在 PostgreSQL 中实现 UPSERT 的惯用方式

假设一个简单的查询：

(SELECT MAX(timestamp) FROM events e WHERE e.id < some_id) 
  + ((SELECT MIN(timestamp) FROM events e WHERE e.id > some_id) 
    - (SELECT MAX(timestamp) FROM events e WHERE e.id < some_id)) / 2

如果 some_id是参数，它会根据某些事件序列找到近似时间戳（它采用前一个和后一个事件并平均它们的时间戳）。

这个查询很好用，现在我想把它打包成一个函数：

CREATE FUNCTION id_to_timestamp(integer) RETURNS timestamp with time zone AS
$BODY$
    (SELECT MAX(timestamp) FROM events e WHERE e.id < $1) 
      + ((SELECT MIN(timestamp) FROM events e WHERE e.id > $1) 
        - (SELECT MAX(timestamp) FROM events e WHERE e.id < $1)) / 2
$BODY$
LANGUAGE sql; …

我有一个模式（称为import），其中数据作为表导入，以及一个处理它们的函数。之后我想将这些表移到另一个模式中（称为data_archive）中。现有功能运行良好，但我找不到更改架构的方法；这是我编写的一个函数：

我的想法是根据selecta 为该管理制作的表格提供的标准创建表格列表，然后遍历此列表并执行以下操作Alter table xxxx SET schema data_archive：

CREATE OR REPLACE FUNCTION archive_datasets()
  RETURNS VOID AS
$BODY$
DECLARE
   table_rec  record;

BEGIN

   FOR table_rec IN
      SELECT t.table_name
      FROM information_schema.tables AS t
      WHERE table_schema = 'import'
      AND quote_ident(t.table_name) IN (
              SELECT "table_name"
              FROM data_sets 
              WHERE status IN ('Processed', 'Archived', 'Deleted')
              ) 

   LOOP
     ALTER TABLE quote_ident(table_rec.table_name) SET schema data_archived;
   END LOOP;

END;
$BODY$
  LANGUAGE plpgsql;

但我收到此错误消息：

ERROR:  syntax error at or near "("
LINE 28: …

Run Code Online (Sandbox Code Playgroud)

我有一个查询问题。我有一个带有汽车及其规格的数据库，每个型号都有与该型号相关的不同汽车及其价格。我想创建一个查询，为我提供每个模型的最低和最高价格。

像这样：

+--------+----------+
| model  | price    |
+--------+----------+
| golf   | 4000     | 
| golf   | 6000     |
| golf   | 10000    | 
| panda  | 3000     | 
| panda  | 5000     |
| panda  | 7000     |
+--------+----------+

查询给了我这个：

+--------+----------+
| model  | price    |
+--------+----------+
| golf   | 4000     | 
| golf   | 10000    | 
| panda  | 3000     | 
| panda  | 7000     |
+--------+----------+

你能帮助我吗？

我在 SQL Server 中有程序可以打印给定国家/地区的所有玩家。我尝试将其转换为 plpgsql，但出现错误。

SQL Server 过程

CREATE PROCEDURE kraj_pilkarze @kraj varchar(30)
AS
DECLARE @idkraj INT
DECLARE @nazwa_zespolu varchar(30)
SELECT @idkraj = id_kraj FROM kraj WHERE @kraj=nazwa
DECLARE kursor_pilk CURSOR
FOR SELECT imie,nazwisko, id_zespol, id_kraj FROM pilkarz
DECLARE @imie varchar(20), @nazwisko varchar(30), @zespol int, @d_kraj int
OPEN kursor_pilk
FETCH NEXT FROM kursor_pilk INTO @imie, @nazwisko,@zespol, @d_kraj
WHILE @@FETCH_STATUS=0
    BEGIN
    IF @d_kraj=@idkraj
        BEGIN
            SELECT @nazwa_zespolu = nazwa FROM zespol WHERE @zespol=id_zespol 
            PRINT @imie+' '+@nazwisko+', '+@nazwa_zespolu
            FETCH NEXT FROM kursor_pilk INTO …

我有一个以以下结尾的函数：

    INSERT INTO configuration_dates (
      cols...
    ) VALUES (
      values...
    ) RETURNING id INTO ret_id;
    RETURN ret_id;

我想删除该INTO ret_id部分，而是执行以下操作：

RETURN (INSERT INTO configuration_dates (
  weekly_date_configuration_id,
  "from",
  "to",
  price,
  activity_configuration_id
) VALUES (
  wdc_id,
  from_ts,
  from_ts + wdc.duration,
  wdc.price,
  wdc.activity_configuration_id
) RETURNING id);

但我还没有找到如何实现这一点。

编辑：添加整个功能

CREATE FUNCTION make_date_from_configuration(wdc_id UUID, from_date DATE)
  RETURNS INTEGER AS $$
DECLARE
  from_dow INT := EXTRACT(isodow FROM from_date); -- day of the week (1 - 7)
  wdc weekly_date_configurations;
  from_ts TIMESTAMP;
  ret_id INTEGER;
BEGIN
  SELECT * …

这些是我创建并插入了一些值的表：

CREATE TABLE DEPARTMENT
(DEPARTMENT_ID NUMBER PRIMARY KEY,
 DEPARTMENT_NAME VARCHAR(30) NOT NULL
 );

CREATE TABLE EMPLOYEES
(EMPLOYEE_ID NUMBER PRIMARY KEY,
 FIRST_NAME VARCHAR(20) NOT NULL,
 LAST_NAME VARCHAR(25) NOT NULL,
 EMAIL VARCHAR(25) NOT NULL,
 PHONE_NUMBER VARCHAR(20) NOT NULL,
 HIRE_DATE DATE NOT NULL,
 JOB_ID NUMBER NOT NULL,
 SALARY DECIMAL NOT NULL,
 DEPARTMENT_ID NUMBER NOT NULL,
 CONSTRAINT emp_job_fk FOREIGN KEY(JOB_ID) REFERENCES JOBS(JOB_ID),
 CONSTRAINT emp_department_fk FOREIGN KEY(DEPARTMENT_ID) REFERENCES DEPARTMENT(DEPARTMENT_ID)
 );

INSERT INTO DEPARTMENT (DEPARTMENT_ID,DEPARTMENT_NAME)
VALUES(1,'IT');
INSERT INTO DEPARTMENT (DEPARTMENT_ID,DEPARTMENT_NAME)
VALUES(2,'Sales');
INSERT INTO DEPARTMENT (DEPARTMENT_ID,DEPARTMENT_NAME)
VALUES(3,'Accounting'); …

我继承了一个缺乏唯一约束的数据库，因此数据被/被复制。我现在正在尝试删除重复的记录，然后添加一个约束来阻止这一点。

我有这个查询：

SELECT count(*) as dacount, substr(group_concat(id), (locate(',', group_concat(id))+ 1))
FROM `game`
group by matchid, ordinal
having dacount > 1
order by dacount desc

这正确地给了id我需要删除的行的s。但问题是，DELETE由于dacountwithhaving参数，我不能将其用作子查询。有没有另一种方法可以做到这一点？

这是我的计划：

DELETE FROM game WHERE id IN (SELECT count(*) as dacount, substr(group_concat(id), (locate(',', group_concat(id))+ 1))
FROM `game`
GROUP BY matchid, ordinal
HAVING dacount > 1)