本文整理汇总了Python中query.Query类的典型用法代码示例。如果您正苦于以下问题:Python Query类的具体用法?Python Query怎么用?Python Query使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Query类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: textBasedUi
def textBasedUi ( ):
"""
Offers 6 options to user. Handles input errors.
"""
userChoice = 0
query = Query( pIndex )
userInput = ""
cosines = 0 #Value for list of cosine values for page ranking
while userInput != 'quit':
print("Enter a query, type (quit) to exit")
userInput = getWord()
userInput = ' '.join(userInput) #convert list of normalized words from user input into single string
if queryWeight == 'nnn':
print("Weighting Query: NNN")
qWeights = queryNNN(userInput)
cosines = scoring(qWeights)
else:
print("Weighting Query: LTC")
qWeights = queryLTC(userInput)
cosines = scoring(qWeights)
if userInput != 'quit':
displayResults(query.stringQuery(userInput), cosines)
print("QUITTING")
'''
开发者ID:nate-robo,项目名称:Search-RecSys,代码行数:26,代码来源:mediaObjectSearchEngine.py
示例2: run
def run(port, name, config):
STUB_RESPONSE = '0.0.0.0'
try:
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.bind(('',port))
except Exception as e:
print 'failed to create socket %s' % e
sys.exit(1)
print 'Running dns server'
try:
while 1:
data, addr = s.recvfrom(1024)
p=Query(data)
# if host is our cdn target
if name in p.domain:
response = handle_response(addr[0], config)
else:
response = p.question(p.domain)
if not response: # couldn't find host
response = STUB_RESPONSE
s.sendto(p.answer(response), addr)
print '%s -> %s' % (p.domain, response)
except KeyboardInterrupt:
print 'Keyboard Interrupt'
s.close()
开发者ID:MengWenkui,项目名称:CDN,代码行数:28,代码来源:dnsserver.py
示例3: main
def main():
args = docopt(__doc__)
sql_str = args['SQL'] or sys.stdin.read()
debug = args['--debug']
execute = args['--execute']
random_seed = args['--random-seed']
if debug:
logging.basicConfig(level=logging.DEBUG)
parsed = parse(sql_str)
relations, conditions = get_relations_and_conditions(parsed)
sample_size = parsed.sample_size if parsed.sample_size != '' else None
query = Query(
relations,
conditions=conditions,
columns=parsed.column_definitions,
sample_size=sample_size,
random_seed=random_seed,
is_top_level=True
)
result = query.execute()
result_str = result.get_cmd_str(output_column_names=True)
if execute:
# explicitly use bash instead of the default for subprocess(..., shell=True) which is sh
result_str = "({})".format(result_str)
proc = subprocess.Popen(['/bin/bash', '-c', result_str])
else:
result_str = result_str + "\n"
print(result_str, end="")
开发者ID:shahin,项目名称:sqltxt,代码行数:33,代码来源:__main__.py
示例4: __init__
def __init__(self, dbconn, table):
Query.__init__(self, dbconn)
self._where = None
self._target = None
self.target(table)
开发者ID:daisaru11,项目名称:myquery,代码行数:7,代码来源:delete.py
示例5: flash
def flash(sqlsession, token, device):
error = False
errors = []
token = None
device = None
if type(token) == int:
token = sqlsession.query(models.Token).filter_by(id=token).first()
if type(device) == int:
device = sqlsession.query(models.Device).filter_by(id=device).first()
if device:
if token:
try:
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((config.api_host, config.api_port))
temporary_token = helpers.generate_token()
q = Query()
q.create_register_webui(config.webui_token, temporary_token)
s.send(q.to_command())
q.create_flash(temporary_token, token.value, device.pubkey)
s.send(q.to_command())
q.create_unregister(temporary_token)
s.send(q.to_command())
s.close()
except Exception:
error = True
errors.append(('flash', 'Connection to device failed.'))
else:
error = True
errors.append(('token', 'Token does not exist.'))
else:
error = True
errors.append(('device', 'Device does not exist.'))
return error, errors
开发者ID:Tiwalun,项目名称:backdoor,代码行数:35,代码来源:token.py
示例6: _delete
def _delete(self):
Query.execute(
'DELETE FROM %s WHERE id=%%s' % self.__table__ ,
self.id,
self.__db__
)
return True
开发者ID:PegasusWang,项目名称:collection_python,代码行数:7,代码来源:model.py
示例7: test_english_highlighted_noop
def test_english_highlighted_noop(self):
phrases = [ Phrase('phrase type', { 'english' : 'foo' }, []),
Phrase('phrase type', { 'english' : 'bar' }, []),
Phrase('phrase type', { 'english' : 'baz' }, []) ]
query = Query('the_table', phrases)
query.set_base_atoms([Atom('atom type', 'ba')])
self.assertEqual(query.get_english_highlighted(), 'Foo bar baz?')
开发者ID:rphilander,项目名称:proteus,代码行数:7,代码来源:test_query.py
示例8: requestAvatarId
def requestAvatarId(self, cred): # pylint: disable=R0201
"""get user id from database"""
args = cred.username.split(SERVERMARK)
if len(args) > 1:
if args[0] == 'adduser':
cred.username = args[1]
password = args[2]
with Transaction():
query = Query('insert into player(name,password) values(?,?)',
list([cred.username.decode('utf-8'), password.decode('utf-8')]))
if not query.success:
if query.msg.startswith('ERROR: constraint failed') \
or 'not unique' in query.msg:
template = m18nE('User %1 already exists')
logInfo(m18n(template, cred.username))
query.msg = srvMessage(template, cred.username)
else:
logInfo(query.msg)
return fail(credError.UnauthorizedLogin(query.msg))
elif args[1] == 'deluser':
pass
query = Query('select id, password from player where name=?',
list([cred.username.decode('utf-8')]))
if not len(query.records):
template = 'Wrong username: %1'
logInfo(m18n(template, cred.username))
return fail(credError.UnauthorizedLogin(srvMessage(template, cred.username)))
userid, password = query.records[0]
# checkPassword uses md5 which cannot handle unicode strings (python 2.7)
defer1 = maybeDeferred(cred.checkPassword, password.encode('utf-8'))
defer1.addCallback(DBPasswordChecker._checkedPassword, userid)
return defer1
开发者ID:jsj2008,项目名称:kdegames,代码行数:32,代码来源:server.py
示例9: find
def find(cls, limit=1000, where=None, order="", operator_where=Query.AND):
where = where or {}
q = Query(cls).select('*')
deleted_keys = []
for key in where:
values = where[key]
# example of usages:
# .find(Person, where={'code_language': (Query.IN, ['ruby', 'python']))
if isinstance(values, tuple):
val = values[1]
if isinstance(values[1], list):
val = tuple(values[1])
q = q.where({key: val}, values[0])
deleted_keys.append(key)
for key in deleted_keys:
del where[key]
q.where(where, operator_where=operator_where).limit(limit).order(order)
result = query(q)
if cls.__name__ in result:
return result[cls.__name__]
return []
开发者ID:felipevolpone,项目名称:alabama_orm,代码行数:25,代码来源:storage.py
示例10: random_tweet
def random_tweet():
tweet = TwitterAPI.get_random_tweet()
tweet_id = tweet['id']
# Store the random tweet
with open('tweets/%d.json' % tweet_id, 'w') as f:
f.write(json.dumps(tweet))
# Get our additional information
query = Query(tweet['text'] + " " + tweet['user']['name'])
query.run()
article = query.get_result_article()
article_file_name = query.get_result_filename()
# Replace all the links in the article
if article is not None:
article = article.replace('/wiki/', 'https://en.wikipedia.org/wiki/')
if article is not None:
markup = TwitterAPI.get_tweet_markup(tweet_id)
parameters = {
'article_html': article,
'article_filename': article_file_name,
'tweet_html': markup,
'ratings': [1, 2, 3, 4, 5],
'tweet_id': tweet_id,
}
return render_template('tweet.html', **parameters)
else:
# We need to find another tweet
return random_tweet()
开发者ID:maddieclayton,项目名称:COS435-project,代码行数:31,代码来源:server.py
示例11: growth
def growth(playerId):
sql = Query()
queries = sql.quering_select("select Round(AVG(AVG1),3) from HitterGames where playerId="+str(playerId)+" Group by year,month")
points = getPointArray(tupleToList(queries))
queries = tupleToList(sql.quering_select("select year,month from HitterGames where playerId="+str(playerId)+" Group by year,month"))
return {"date":queries, "points":points}
开发者ID:aperturecs,项目名称:baseball,代码行数:7,代码来源:algorithm.py
示例12: load
def load(self):
query = Query(self._connection)
query.SELECT("gid", self.name)
query.SELECT("the_geom", self.name, "AsText")
query.SELECT(self._primary, self.name)
for key, gen in self._fields:
query.SELECT(key, self.name)
whereList = []
try:
for entry in self._subset:
item = self.name + "." + self._primary + "='" + entry + "'"
whereList.append(item)
query.where = " OR ".join(whereList)
except TypeError:
pass
polyDict = PolygonDictionary()
pairs = []
for entry in query:
d = []
for key, gen in self._fields:
d.append((gen, entry[key]))
data = Dictionary()
data.update(d)
p = GeneralizedPolygon(enum.ABSTRACT, entry["gid"], entry["the_geom"], data, self)
polyKey = keygen(entry[self._primary])
pairs.append((polyKey, p))
polyDict.update(pairs)
return polyDict
开发者ID:GaminiKumara,项目名称:eden,代码行数:28,代码来源:map.py
示例13: select
def select(*columns):
cursor = Model.conn.cursor()
query = Query(cursor)
if columns:
query.select(*columns)
return query
开发者ID:mrrainwater,项目名称:CookieMonster,代码行数:8,代码来源:model.py
示例14: reserveGameId
def reserveGameId(self, gameid):
"""the game server proposes a new game id. We check if it is available
in our local data base - we want to use the same gameid everywhere"""
with Internal.db:
query = Query('insert into game(id,seed) values(?,?)',
(gameid, self.connection.url), mayFail=True, failSilent=True)
if query.rowcount() != 1:
return Message.NO
return Message.OK
开发者ID:KDE,项目名称:kajongg,代码行数:9,代码来源:client.py
示例15: test_where_does_not_mutate_query
def test_where_does_not_mutate_query(self):
with mock.patch("query.Repo") as Repo:
q = Query(TunaCasserole).where(my_attr=5)
q.where(my_attr=3)
list(q)
repo = Repo.return_value
repo.where.assert_called_with([], my_attr=5)
repo.where.return_value.select.assert_called_with(
"id", "created_at", "updated_at", "my_attr")
开发者ID:ECESeniorDesign,项目名称:lazy_record,代码行数:9,代码来源:test_query.py
示例16: simmilar
def simmilar(playerId):
sql = Query()
p = tupleToList(sql.quering_select("Select AVG from HitterProfiles where playerId="+str(playerId)))
players_avg = tupleToList(sql.quering_select("Select playerId from HitterProfiles where (AVG-"+str(p)+")>=0 and playerId!="+str(playerId)+" ORDER BY (AVG-"+str(p)+")"))
result = []
result.append(players_avg[0])
result.append(players_avg[1])
result.append(players_avg[2])
return result
开发者ID:aperturecs,项目名称:baseball,代码行数:9,代码来源:algorithm.py
示例17: get
def get(self, filename):
"""
Return an object for the given filename.
"""
filename = os.path.realpath(filename)
if not os.path.exists(filename):
raise OSError('no such file or directory %s' % filename)
q = Query(self, filename=filename)
yield kaa.inprogress(q)
yield q.get()
开发者ID:clones,项目名称:kaa,代码行数:10,代码来源:client.py
示例18: test_ordering_does_not_mutate
def test_ordering_does_not_mutate(self):
with mock.patch("query.Repo") as Repo:
q = Query(TunaCasserole)
q.order_by(id="asc")
list(q.order_by(id="desc"))
repo = Repo.return_value
repo.order_by.assert_called_with(id="desc")
order = repo.order_by.return_value
order.select.assert_called_with("id", "created_at",
"updated_at", "my_attr")
开发者ID:ECESeniorDesign,项目名称:lazy_record,代码行数:10,代码来源:test_query.py
示例19: exist
def exist(cls, where=None, uuid=None):
where = where or {}
if uuid:
where['uuid'] = uuid
q = Query(cls).select(["count(*)"]).where(where).limit(1)
sql, where = q.query()
connection.my_connection().execute(sql, where)
results = connection.my_connection().fetchall()
return results[0][0] > 0
开发者ID:felipevolpone,项目名称:alabama_orm,代码行数:10,代码来源:storage.py
示例20: test_validation
def test_validation(self):
atom_a = Atom('a', 'a')
atom_b = Atom('b', 'b')
atoms = [atom_a, atom_b]
phrase_aa = Phrase('phrase aa', {}, [atom_a, atom_a])
phrase_ab = Phrase('phrase bb', {}, [atom_a, atom_b])
query_good = Query('query good', [phrase_ab])
query_bad = Query('query bad', [phrase_aa])
self.assertTrue(query_good.validate(atoms))
self.assertFalse(query_bad.validate(atoms))
开发者ID:rphilander,项目名称:proteus,代码行数:10,代码来源:test_query.py
注:本文中的query.Query类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论