sql

package
v0.0.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 23, 2024 License: AGPL-3.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var FilterSuffix = map[string]string{
	"eq":     "==",
	"ne":     "!=",
	"lt":     "<",
	"lte":    "<=",
	"gt":     ">",
	"gte":    ">=",
	"in":     "IN",
	"not_in": "NOT IN",
}

Functions

func BuildCombinedMetaQuery 

func BuildCombinedMetaQuery(keys dataloader.Keys, param *QueryBuilderParam) ([]byte, error)

func BuildCombinedRelationQuery 

func BuildCombinedRelationQuery(relationType string, parentModel string, arg *shared.CommonSystemParams) (*string, *string, error)

func CommonDocTransformation 

func CommonDocTransformation(model *protobuff.ModelType, local string, result map[string]interface{}, classification *FieldClassification) (*shared.DefaultDocumentStructure, error)

func ConditionBuilder 

func ConditionBuilder(variable string, args map[string]interface{}, modelType *protobuff.ModelType) (map[string][]string, error)

func FilterBuilder 

func FilterBuilder(variable string, where map[string]interface{}, modelType *protobuff.ModelType) ([]string, error)

func LimitBuilder 

func LimitBuilder(param *graphql.ResolveParams) (int, int)

func MediaDocTransformation 

func MediaDocTransformation(docType string, result map[string]interface{}) (*protobuff.FileDetails, error)

func RootConnectionResolverQueryBuilder 

func RootConnectionResolverQueryBuilder(param *shared.CommonSystemParams) (string, error)

func RootResolverMediaQueryBuilder 

func RootResolverMediaQueryBuilder(param *graphql.ResolveParams) (string, error)

func RootResolverQueryBuilder 

func RootResolverQueryBuilder(param shared.CommonSystemParams, returnCount bool) (*string, error)

func SelectBuilder 

func SelectBuilder(mv string, local string, modelType *protobuff.ModelType, returnCount bool) []string

Types

type FieldClassification 

type FieldClassification struct {
	MultilineFields []string
	DoubleFields    []string
	PictureField    []string
	GalleryField    []string
	ListFields      []string
	RepeatedFields  map[string][]*protobuff.FieldInfo
}

type Meta 

type Meta struct {
	ID    string `bun:",pk,type:varchar(36),notnull" json:"id"`
	DocID string `bun:",notnull" json:"doc_id"`

	CreatedAt time.Time `bun:",notnull,default:current_date" json:"created_at"`
	UpdatedAt time.Time `bun:",notnull,default:current_date" json:"updated_at"`

	Status string `bun:",notnull" json:"status"`
}

type ProjectSqlDriver added in v0.0.6 

type ProjectSqlDriver struct {
	ORM              *bun.DB
	DriverCredential *protobuff.DriverCredentials
}

func GetProjectSQLDriver added in v0.0.6 

func GetProjectSQLDriver(driverCredentials *protobuff.DriverCredentials) (*ProjectSqlDriver, error)

func (*ProjectSqlDriver) AddATeamMemberToProject added in v0.0.6 

func (S *ProjectSqlDriver) AddATeamMemberToProject(ctx context.Context, projectId string, memberData map[string]interface{}) error

func (*ProjectSqlDriver) AddAuthAddOns added in v0.0.6 

func (S *ProjectSqlDriver) AddAuthAddOns(ctx context.Context, project *protobuff.Project, auth map[string]interface{}) error

func (*ProjectSqlDriver) AddCollection added in v0.0.6 

func (S *ProjectSqlDriver) AddCollection(ctx context.Context, projectId string) (*string, error)

func (*ProjectSqlDriver) AddDataToTableOrCollection added in v0.0.9 

func (S *ProjectSqlDriver) AddDataToTableOrCollection(ctx context.Context, table string, data map[string]interface{}) error

func (*ProjectSqlDriver) AddDocumentToProject added in v0.0.6 

func (S *ProjectSqlDriver) AddDocumentToProject(ctx context.Context, projectId string, modelName string, doc *shared.DefaultDocumentStructure) (interface{}, error)

func (*ProjectSqlDriver) AddFieldToModel added in v0.0.6 

func (S *ProjectSqlDriver) AddFieldToModel(ctx context.Context, param shared.CommonSystemParams, isUpdate bool, repeatedGroupIdentifier *string) (*protobuff.ModelType, error)

func (*ProjectSqlDriver) AddModel added in v0.0.6 

func (S *ProjectSqlDriver) AddModel(ctx context.Context, project *protobuff.Project, name string, singleRecord bool) (*protobuff.ProjectSchema, error)

func (*ProjectSqlDriver) AddRelationFields added in v0.0.6 

func (S *ProjectSqlDriver) AddRelationFields(ctx context.Context, from *protobuff.ConnectionType, to *protobuff.ConnectionType) error

func (*ProjectSqlDriver) AddTeamMetaInfo added in v0.0.6 

func (S *ProjectSqlDriver) AddTeamMetaInfo(ctx context.Context, docs []*protobuff.SystemUser) ([]*protobuff.SystemUser, error)

func (*ProjectSqlDriver) CheckCollectionExists added in v0.0.6 

func (S *ProjectSqlDriver) CheckCollectionExists(ctx context.Context, projectId string) (bool, error)

func (*ProjectSqlDriver) CheckDBExists added in v0.0.6 

func (S *ProjectSqlDriver) CheckDBExists(ctx context.Context, projectId string) (bool, error)

func (*ProjectSqlDriver) CheckOneToOneRelationExists added in v0.0.6 

func (S *ProjectSqlDriver) CheckOneToOneRelationExists(ctx context.Context, param *shared.ConnectDisconnectParam) (bool, error)

func (*ProjectSqlDriver) ConnectBuilder added in v0.0.6 

func (S *ProjectSqlDriver) ConnectBuilder(ctx context.Context, param shared.CommonSystemParams) error

func (*ProjectSqlDriver) ConvertModel added in v0.0.6 

func (S *ProjectSqlDriver) ConvertModel(ctx context.Context, project *protobuff.Project, modelName string) error

func (*ProjectSqlDriver) CountDocOfProject added in v0.0.6 

func (S *ProjectSqlDriver) CountDocOfProject(ctx context.Context, param *shared.CommonSystemParams) (interface{}, error)

func (*ProjectSqlDriver) CountDocOfProjectBytes added in v0.0.6 

func (S *ProjectSqlDriver) CountDocOfProjectBytes(ctx context.Context, param *shared.CommonSystemParams) ([]byte, error)

func (*ProjectSqlDriver) CountMedias added in v0.0.6 

func (S *ProjectSqlDriver) CountMedias(ctx context.Context, projectId string, param *graphql.ResolveParams) (int, error)

func (*ProjectSqlDriver) CountMultiDocumentOfProject added in v0.0.6 

func (S *ProjectSqlDriver) CountMultiDocumentOfProject(ctx context.Context, param shared.CommonSystemParams, previewMode bool) (int, error)

func (*ProjectSqlDriver) CreateMediaDocument added in v0.0.6 

func (S *ProjectSqlDriver) CreateMediaDocument(ctx context.Context, projectId string, media *protobuff.FileDetails) (*protobuff.FileDetails, error)

func (*ProjectSqlDriver) CreateRelation added in v0.0.6 

func (S *ProjectSqlDriver) CreateRelation(ctx context.Context, projectId string, relation *shared.EdgeRelation) error

func (*ProjectSqlDriver) CreateTableOrCollection added in v0.0.9 

func (S *ProjectSqlDriver) CreateTableOrCollection(ctx context.Context, name string, properties map[string]string) error

func (*ProjectSqlDriver) DeleteDataFromTableOrCollection added in v0.0.9 

func (S *ProjectSqlDriver) DeleteDataFromTableOrCollection(ctx context.Context, table string, id string) error

func (*ProjectSqlDriver) DeleteDocumentFromProject added in v0.0.6 

func (S *ProjectSqlDriver) DeleteDocumentFromProject(ctx context.Context, param shared.CommonSystemParams) error

func (*ProjectSqlDriver) DeleteDocumentRelation added in v0.0.6 

func (S *ProjectSqlDriver) DeleteDocumentRelation(ctx context.Context, param shared.CommonSystemParams) error

func (*ProjectSqlDriver) DeleteDocumentsFromProject added in v0.0.6 

func (S *ProjectSqlDriver) DeleteDocumentsFromProject(ctx context.Context, param shared.CommonSystemParams) error

func (*ProjectSqlDriver) DeleteMediaFile added in v0.0.6 

func (S *ProjectSqlDriver) DeleteMediaFile(ctx context.Context, param shared.CommonSystemParams) error

func (*ProjectSqlDriver) DeleteProject added in v0.0.6 

func (S *ProjectSqlDriver) DeleteProject(ctx context.Context, projectId string) error

func (*ProjectSqlDriver) DeleteRelation added in v0.0.6 

func (S *ProjectSqlDriver) DeleteRelation(ctx context.Context, param *shared.ConnectDisconnectParam, id string) error

func (*ProjectSqlDriver) DisconnectBuilder added in v0.0.6 

func (S *ProjectSqlDriver) DisconnectBuilder(ctx context.Context, param shared.CommonSystemParams) error

func (*ProjectSqlDriver) DropConnections added in v0.0.6 

func (S *ProjectSqlDriver) DropConnections(ctx context.Context, projectId string, from *protobuff.ConnectionType, to *protobuff.ConnectionType) error

func (*ProjectSqlDriver) DropField added in v0.0.6 

func (S *ProjectSqlDriver) DropField(ctx context.Context, param shared.CommonSystemParams) error

func (*ProjectSqlDriver) DropTableOrCollection added in v0.0.9 

func (S *ProjectSqlDriver) DropTableOrCollection(ctx context.Context, name string) error

func (*ProjectSqlDriver) DuplicateModel added in v0.0.6 

func (S *ProjectSqlDriver) DuplicateModel(ctx context.Context, project *protobuff.Project, modelName, newName string) (*protobuff.ProjectSchema, error)

func (*ProjectSqlDriver) GetAllRelationDocumentsOfSingleDocument added in v0.0.6 

func (S *ProjectSqlDriver) GetAllRelationDocumentsOfSingleDocument(ctx context.Context, from string, arg *shared.CommonSystemParams) (interface{}, error)

func (*ProjectSqlDriver) GetLoggedInProjectUser added in v0.0.6 

func (S *ProjectSqlDriver) GetLoggedInProjectUser(ctx context.Context, param *shared.CommonSystemParams) (*shared.DefaultDocumentStructure, error)

func (*ProjectSqlDriver) GetProjectUser added in v0.0.6 

func (S *ProjectSqlDriver) GetProjectUser(ctx context.Context, phone, email, projectId string) (*shared.DefaultDocumentStructure, error)

func (*ProjectSqlDriver) GetProjectUsers added in v0.0.6 

func (S *ProjectSqlDriver) GetProjectUsers(ctx context.Context, projectId string, keys []string) (map[string]*shared.DefaultDocumentStructure, error)

func (*ProjectSqlDriver) GetRelationIds added in v0.0.6 

func (S *ProjectSqlDriver) GetRelationIds(ctx context.Context, param *shared.ConnectDisconnectParam) ([]string, error)

func (*ProjectSqlDriver) GetSingleProjectDocument added in v0.0.6 

func (S *ProjectSqlDriver) GetSingleProjectDocument(ctx context.Context, param shared.CommonSystemParams) (*shared.DefaultDocumentStructure, error)

func (*ProjectSqlDriver) GetSingleProjectDocumentBytes added in v0.0.6 

func (S *ProjectSqlDriver) GetSingleProjectDocumentBytes(ctx context.Context, param shared.CommonSystemParams) ([]byte, error)

func (*ProjectSqlDriver) GetSingleProjectDocumentRevisions added in v0.0.6 

func (S *ProjectSqlDriver) GetSingleProjectDocumentRevisions(ctx context.Context, param shared.CommonSystemParams) ([]*shared.DocumentRevisionHistory, error)

func (*ProjectSqlDriver) GetSingleRawDocumentFromProject added in v0.0.6 

func (S *ProjectSqlDriver) GetSingleRawDocumentFromProject(ctx context.Context, param shared.CommonSystemParams) (interface{}, error)

func (*ProjectSqlDriver) ListMedias added in v0.0.6 

func (S *ProjectSqlDriver) ListMedias(ctx context.Context, projectId string, param *graphql.ResolveParams) ([]*protobuff.FileDetails, error)

func (*ProjectSqlDriver) NewInsertableRelations added in v0.0.6 

func (S *ProjectSqlDriver) NewInsertableRelations(ctx context.Context, param *shared.ConnectDisconnectParam) ([]string, error)

func (*ProjectSqlDriver) QueryMultiDocumentOfProject added in v0.0.6 

func (S *ProjectSqlDriver) QueryMultiDocumentOfProject(ctx context.Context, param shared.CommonSystemParams) ([]*shared.DefaultDocumentStructure, error)

func (*ProjectSqlDriver) QueryMultiDocumentOfProjectBytes added in v0.0.6 

func (S *ProjectSqlDriver) QueryMultiDocumentOfProjectBytes(ctx context.Context, param shared.CommonSystemParams) ([]byte, error)

func (*ProjectSqlDriver) RelationshipDataLoader added in v0.0.6 

func (S *ProjectSqlDriver) RelationshipDataLoader(ctx context.Context, param *shared.CommonSystemParams, connection map[string]interface{}) (interface{}, error)

func (*ProjectSqlDriver) RelationshipDataLoaderBytes added in v0.0.6 

func (S *ProjectSqlDriver) RelationshipDataLoaderBytes(ctx context.Context, param *shared.CommonSystemParams, connection map[string]interface{}) ([]byte, error)

func (*ProjectSqlDriver) RemoveATeamMemberFromProject added in v0.0.6 

func (S *ProjectSqlDriver) RemoveATeamMemberFromProject(ctx context.Context, projectId string, memberId string) error

func (*ProjectSqlDriver) RemoveAuthAddOns added in v0.0.6 

func (S *ProjectSqlDriver) RemoveAuthAddOns(ctx context.Context, project *protobuff.Project, option map[string]interface{}) error

func (*ProjectSqlDriver) RenameField added in v0.0.6 

func (S *ProjectSqlDriver) RenameField(ctx context.Context, oldFieldName string, repeatedGroupIdentifier *string, param shared.CommonSystemParams) error

func (*ProjectSqlDriver) RenameModel added in v0.0.6 

func (S *ProjectSqlDriver) RenameModel(ctx context.Context, project *protobuff.Project, modelName, newName string) error

func (*ProjectSqlDriver) RunMigration added in v0.0.6 

func (S *ProjectSqlDriver) RunMigration(ctx context.Context, projectId string) error

func (*ProjectSqlDriver) TransferProject added in v0.0.6 

func (S *ProjectSqlDriver) TransferProject(ctx context.Context, userId, from, to string) error

func (*ProjectSqlDriver) UpdateDataToTableOrCollection added in v0.0.9 

func (S *ProjectSqlDriver) UpdateDataToTableOrCollection(ctx context.Context, table string, data map[string]interface{}) (interface{}, error)

func (*ProjectSqlDriver) UpdateDocumentOfProject added in v0.0.6 

func (S *ProjectSqlDriver) UpdateDocumentOfProject(ctx context.Context, param shared.CommonSystemParams, doc *shared.DefaultDocumentStructure, replace bool) error

type QueryBuilderParam 

type QueryBuilderParam struct {
	CollectionName string
	RelationName   string
	Args           map[string]interface{}
	ParentModel    string
	ModelType      *protobuff.ModelType
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.