Elep

from django.db import models
from django.contrib.auth.models import User
from picklefield.fields import PickledObjectField

class SnowflakeAuthentication(models.Model):
    account = models.CharField(max_length=122)
    user = models.CharField(max_length=122)
    password = models.CharField(max_length=122)
    role = models.CharField(max_length=122)
    user_id = models.ForeignKey(User, on_delete=models.CASCADE)

class SubscriptionflowAuthentication(models.Model):
    subdomain = models.CharField(max_length=122)
    client_id = models.CharField(max_length=122)
    client_secret = models.CharField(max_length=122)
    user_id = models.ForeignKey(User, on_delete=models.CASCADE)

class MappingDetail(models.Model):
    direct_list = PickledObjectField()
    direct_mapping_list = PickledObjectField()
    snowflake_static = PickledObjectField()
    warehouse = models.CharField(max_length=122)
    retention_database = models.CharField(max_length=122)
    database = models.CharField(max_length=122)
    schema = models.CharField(max_length=122)
    table = models.CharField(max_length=122)
    max_id = models.IntegerField()
    user_id = models.ForeignKey(User, on_delete=models.CASCADE)
    snowflake_auth_id = models.ForeignKey(SnowflakeAuthentication, on_delete=models.CASCADE)
    sf_auth_id = models.ForeignKey(SubscriptionflowAuthentication, on_delete=models.CASCADE)

class SyncMappingRecord(models.Model):
    event_number = models.IntegerField()
    created_on = models.DateTimeField()
    mapping_id = models.ForeignKey(MappingDetail, on_delete=models.CASCADE)
    user_id = models.ForeignKey(User, on_delete=models.CASCADE)
    snowflake_auth_id = models.ForeignKey(SnowflakeAuthentication, on_delete=models.CASCADE)
    sf_auth_id = models.ForeignKey(SubscriptionflowAuthentication, on_delete=models.CASCADE)