import sys
import gzip


from gavo import base

destFile = "/var/svn/space_for_gavo/dumps/obsposppmx.txt.gz"

conn = base.getDBConnection("trustedquery")
c = conn.cursor()
#c.execute("SET work_mem=500000")
c.execute("""select	pp.ipix,
							pmRA,
							pmDE,
							alphaFloat AS alphaObs,
							deltaFloat AS deltaObs,
							'2000-01-01' AS epoch,
							Cmag AS mag,
							'ppmx' AS source,
							localid AS f_key
						FROM ppmx.data
							JOIN usnob.ppmxcross as pp
							ON ppmxid=localid
						ORDER BY pp.ipix""")
out = gzip.open(destFile, "w")

while 1:
	rec = c.fetchone()
	if not rec:
		break
	try:
		if rec[2]!=None:
			out.write(("%023d %+07.3f %+07.3f %011.7f %+12.8f %22s %4.2f"
				" %5s %20s\n")%rec)
		else:
			out.write(("%023d %7s %7s %011.7f %+12.8f %22s %4.1f"
				" %5s %20s\n")%rec)
	except TypeError:
		sys.stderr.write("Bad record: %s"%repr(rec))