Commit ffaad6ee authored by Libor Peltan's avatar Libor Peltan Committed by Daniel Salzman

sql import: support for slave mode (replication)

parent 44785838
......@@ -38,6 +38,7 @@ fix_absolute = False
storage = os.getcwd()
knotc_binary = "knotc"
knotc_socket = None
slave_mode = False
class Domains(SQLObject):
# id = IntCol() # implicitly there
......@@ -121,8 +122,9 @@ def zone_template(zone):
return None
def knotc_send(type, zone):
global slave_mode
if type == 0:
knotc_single("zone-reload", zone)
knotc_single("zone-reload" if not slave_mode else "zone-refresh", zone)
......@@ -156,11 +158,13 @@ def print_record(record, outfile):
def print_domain(domain, change_type = 0, txn = None):
global knotc_socket
global slave_mode
dn = domain_id2name(domain, txn) if str(domain).isdigit() else domain
f = open(zone_storage(dn), "w")
for r in domain_get_records(domain, txn):
print_record(r, f)
if not slave_mode:
f = open(zone_storage(dn), "w")
for r in domain_get_records(domain, txn):
print_record(r, f)
if knotc_socket is not None:
knotc_send(change_type, dn)
print("Updated zone %s" % dn, file=sys.stderr)
......@@ -215,6 +219,7 @@ def main():
global soa_serial
global fix_absolute
global connection
global slave_mode
argp = argparse.ArgumentParser(prog='dns_sql2zf', description="Export DNS records from Mysql or Postgres DB into zonefile.", epilog="(C) CZ.NIC, GPLv3") # TODO better epilog
argp.add_argument(dest='domains', metavar='zone', nargs='*', help='Zone to be exported.')
......@@ -226,6 +231,7 @@ def main():
argp.add_argument('--absolute-names', dest='fix_absolute', action='store_true', help="Interpret names in records' contents (e.g. CNAME, NS...) as absolute even if w/o trailing dot.")
argp.add_argument('--from-changes', dest='from_changes', metavar="from_id", nargs='?', const=[0], help="Export zones listed in extra 'changes' table.")
argp.add_argument('--knotc', dest='knotc_socket', metavar='knot_socket', nargs=1, help="Notify Knot DNS about changes (requires: $PATH/knotc).")
argp.add_argument('--slave', dest='slave', action='store_true', help="Don't generate zonefiles, use 'knotc zone-refresh' instead of zone-reload.")
argp.add_argument('--version', action='version', version='dns_sql2zf 0.1')
args = argp.parse_args()
......@@ -244,6 +250,9 @@ def main():
if args.knotc_socket is not None:
knotc_socket = args.knotc_socket[0]
if args.slave:
slave_mode = True
connection = connectionForURI(args.dburi[0])
sqlhub.processConnection = connection
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment