root/management/bs-admin/trunk/sync_elgg_trac.py

#!/usr/bin/python
import psycopg2

try:
  conn = psycopg2.connect("dbname='elgg' user='user' host='localhost' password='changeme'")
except:
  print "Unable to connect to the db"

try:
  conn2 = psycopg2.connect("dbname='project_meta' host='localhost' user='user' password='changeme'")
except:
  print "Unable to connect to the db"

sql = "SELECT username FROM elgg_users"
sql2 = "SELECT short_name FROM project_request_project"

cursor = conn.cursor()
cursor2 = conn2.cursor()

elgg_shortnames = []
pm_shortnames = []
diff_shortnames = []

cursor.execute(sql)
rows = cursor.fetchall()

for row in rows:
  elgg_shortnames.append(row[0])

cursor2.execute(sql2)

rows2 = cursor2.fetchall()

for row in rows2:
  pm_shortnames.append(row[0])

diff = set(pm_shortnames).difference(set(elgg_shortnames))

for each in diff:
  diff_shortnames.append(each)

for shortname in diff_shortnames:
  username_sql = "SELECT username FROM auth_user WHERE id=(SELECT owner_id FROM project_request_project WHERE short_name='%s')" % (shortname)
  project_name_sql = "SELECT name FROM project_request_project WHERE short_name='%s'" % (shortname)
  cursor2.execute(username_sql)
  rows = cursor2.fetchall()
  username = rows[0][0]
  cursor2.execute(project_name_sql)
  rows = cursor2.fetchall()
  project_name = rows[0][0]

  sql = "SELECT ident FROM elgg_users WHERE username='%s'" % (username)
  cursor.execute(sql)
  value = cursor.fetchall()
  try:
    ownerid = value[0][0]
  except:
    print value
    print username
    continue
  sql = "INSERT INTO elgg_users (username, name, active, owner, user_type, moderation) VALUES ('%s', '%s', 'yes', '%s', 'project', 'no');" % (shortname, project_name, ownerid)
  cursor.execute(sql)
  conn.commit()