|
def write(self,sql,param,iscommit=True): 153 # animal_categories = [['snake', 'reptile'],
154 # ['frog', 'amphibian'],
155 # ['tuna', 'fish'],
156 # ['racoon', 'mammal']]
157 # cursor.executemany('''insert into animal (name, category)
158 # values (%s, %s)''', animal_categories)
159 # '''sql="insert into cdinfo values(%s,%s,%s,%s,%s)"
160 # param should be tuple or list
161 # param=((title,singer,imgurl,url,alpha))
162 # return update row num
163 # can exec update or delete opation
164 # batch insert or update ,param like this:
165 # param=((title,singer,imgurl,url,alpha),(title2,singer2,imgurl2,url2,alpha2))
166 # '''
167 try:
168 cursor = self.connection.cursor()
169 n = cursor.executemany(sql,param)
170 # raise
171 # print n
172 if iscommit :
173 self.connection.commit()
174 return n
175 except:
176 print 'Write MysqlDB Error!'
177 self.connection.rollback()
178 return -1 |
|
|