Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import mysql.connector
- class Dao:
- cnx=0
- cursor=0
- def getFeedKeysFromCtrl(self,registerId,feedId,maxFeedKey,minFeedKey):
- cnx = mysql.connector.connect(user='root', password='password-1',
- host='127.0.0.1',
- database='demo_db')
- crsA = cnx.cursor()
- qury="select distinct substr(cstone_feed_key,1,7) uniq_feed_keys from cstone_ingestion_ctrl where register_id= %d and feed_id = %d and (cstone_feed_key between %d and %d);"%(registerId,feedId,minFeedKey*1000,maxFeedKey*1000)
- crsA.execute(qury)
- feedKeysDetails=crsA.fetchall()
- loadedFeedKeys=[int(i[0]) for i in feedKeysDetails]
- return loadedFeedKeys
Add Comment
Please, Sign In to add comment