Как я могу записать свои собственные агрегатные функции с sqlalchemy?

ASP.NET автоматически вызывает UrlDecode() при доступе к свойству по индексу ключа (т. Е. (Request.QueryString["key"]).

Если вы хотите, чтобы оно было закодировано, просто выполните:

HttpUtility.UrlEncode(Request.QueryString["key"]);

С точки зрения амперсанда, в частности, это особый случай, поскольку он уже используется в качестве разделителя строки запроса. URL Кодирование и декодирование амперсанда всегда должно давать вам & именно по этой причине.

5
задан Mel 1 May 2017 в 08:27
поделиться

2 ответа

Создание новых агрегатных функций зависит от серверной части и должно выполняться напрямую с API подчеркивающего соединения. SQLAlchemy не предлагает средство для их создания.

Однако после создания вы можете просто использовать их в SQLAlchemy в обычном режиме.

Пример:

import sqlalchemy
from sqlalchemy import Column, Table, create_engine, MetaData, Integer
from sqlalchemy import func, select
from sqlalchemy.pool import StaticPool
from random import randrange
import numpy
import sqlite3

class NumpyVarAggregate(object):
  def __init__(self):
    self.values = []
  def step(self, value):
    self.values.append(value)
  def finalize(self):
    return numpy.array(self.values).var()

def sqlite_memory_engine_creator():
    con = sqlite3.connect(':memory:')
    con.create_aggregate("np_var", 1, NumpyVarAggregate)
    return con

e = create_engine('sqlite://', echo=True, poolclass=StaticPool,
                  creator=sqlite_memory_engine_creator)
m = MetaData(bind=e)
t = Table('mytable', m, 
            Column('id', Integer, primary_key=True),
            Column('number', Integer)
          )
m.create_all()

Теперь для тестирования:

# insert 30 random-valued rows
t.insert().execute([{'number': randrange(100)} for x in xrange(30)])

for row in select([func.avg(t.c.number), func.np_var(t.c.number)]).execute():
    print 'RESULT ROW: ', row

Это печатает (с включенным эхо-сигналом SQLAlchemy):

2009-06-15 14:55:34,171 INFO sqlalchemy.engine.base.Engine.0x...d20c PRAGMA 
table_info("mytable")
2009-06-15 14:55:34,174 INFO sqlalchemy.engine.base.Engine.0x...d20c ()
2009-06-15 14:55:34,175 INFO sqlalchemy.engine.base.Engine.0x...d20c 
CREATE TABLE mytable (
    id INTEGER NOT NULL, 
    number INTEGER, 
    PRIMARY KEY (id)
)
2009-06-15 14:55:34,175 INFO sqlalchemy.engine.base.Engine.0x...d20c ()
2009-06-15 14:55:34,176 INFO sqlalchemy.engine.base.Engine.0x...d20c COMMIT
2009-06-15 14:55:34,177 INFO sqlalchemy.engine.base.Engine.0x...d20c INSERT
INTO mytable (number) VALUES (?)
2009-06-15 14:55:34,177 INFO sqlalchemy.engine.base.Engine.0x...d20c [[98], 
[94], [7], [1], [79], [77], [51], [28], [85], [26], [34], [68], [15], [43], 
[52], [97], [64], [82], [11], [71], [27], [75], [60], [85], [42], [40], 
[76], [12], [81], [69]]
2009-06-15 14:55:34,178 INFO sqlalchemy.engine.base.Engine.0x...d20c COMMIT
2009-06-15 14:55:34,180 INFO sqlalchemy.engine.base.Engine.0x...d20c SELECT
avg(mytable.number) AS avg_1, np_var(mytable.number) AS np_var_1 FROM mytable
2009-06-15 14:55:34,180 INFO sqlalchemy.engine.base.Engine.0x...d20c []
RESULT ROW: (55.0, 831.0)

Обратите внимание, что я не использовал ORM SQLAlchemy (использовалась только часть SQLAlchemy с выражениями sql), но вы также можете использовать ORM.

10
ответ дан 14 December 2019 в 01:15
поделиться

сначала вам нужно импортировать функцию из sqlalchemy

, вы можете написать

func.avg ('fieldname')

или func.avg ('fieldname'). Label ('user_deined')

или вы можете получить дополнительную информацию

http://www.sqlalchemy.org/docs/05/ormtutorial.html#using-subqueries

-1
ответ дан 14 December 2019 в 01:15
поделиться
Другие вопросы по тегам:

Похожие вопросы: