import sys
import gzip

from gavo import base

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

conn = base.getDBConnection("trustedquery")
c = conn.cursor()
c.execute("SET work_mem=500000")
c.close()
c = s.connection.cursor("foo")
c.execute("""SELECT
							pp.ipix,
							NULL,
							NULL,
							raj2000 AS alphaObs,
							dej2000 AS deltaObs,
							jd::DATE AS epoch,
							Kmag AS mag,
							'2mas' AS source,
							mainid AS f_key
						FROM twomass.data
							JOIN usnob.twomasscross as pp
							ON twomassid=mainid
						ORDER BY pp.ipix""")
out = gzip.open(destFile, "w")

while 1:
	badRecs = 0
	recs = c.fetchmany(500)
	if not recs:
		break
	for rec in recs:
		try:
			out.write(("%023d %7s %7s %011.7f %+12.8f %22s %4.2f"
				" %5s %20s\n")%rec)
		except TypeError:
			badRecs += 1
	#		sys.stderr.write("Bad record: %s"%repr(rec))
sys.stderr.write("%d bad records.\n"%badRecs)