bintang 0.2.30

A tiny and temporary db for quick data cleansing and transformation. It is a high-level Python coding and would help any Pythonistas up to speed with ETL work.

Bintang

A tiny and temporary db for quick data cleansing and transformation. It is a high-level Python coding and would help any Pythonistas up to speed with ETL work.

Table of Contents

• Bintang

  • How to get started

  • Common Functions

  • Other Functions/attributes

  • Special Functions

How to get started

Requirements

1. Python 3.10 or higher

Some functions require other packages to work. These packages can be installed from pypi using the pip package manager. Here is a list of the functions and its dependencies:

Functions	Packages
create_linked_table(), read_sql() and to_sql()	pyodbc or psycopg (postgresql specific)
read_excel()	openpyxl (xlsx) and xlrd (xls)
to_excel()	openpyxl (xlsx) and xlwt (xls)
valrows(), validate()	python-dateutil
fuzzy_cmprows()	rapidfuzz (faster than the built-in difflib.SequenceMatcher)

Installation

pip install bintang

# or want to target specific "extras" as defined inside the pyproject.toml, pick one below:
# pip install "bintang[database]" # if you want external package pyodbc and psycopg to be installed.
# pip install "bintang[excel]" # if you want external packages openpyxl, xlrd and xlwt to be installed.
# pip install "bintang[all]" # if you want all external packages to be installed.

Examples of Usage

from bintang import Bintang # import the package
bt = Bintang()              # bintang object created

bt.create_table('Person')
print(bt  )
# {
#    "name": null,
#    "tables": [
#    "Person"
#    ]
# }

Use insert function to populate a table. The parameters are dict/columns and values.

# Create a couple of tables and use insert function to insert data.
bt.create_table('Person')

bt['Person'].insert({'id':1,'name':'John','surname':'Smith','address':'1 Station St'})
bt['Person'].insert(['id','name','surname','hobby','address'],[2,'Jane','Brown','Digging','8 Parade Rd'])
bt['Person'].insert(['id','name','surname','Address'], [3,'Okie','Dokie', '7 Ocean Rd'])
bt['Person'].insert((4,'Maria','Digging','7 Heaven Ave'), ('id','name','hobby','Address'))
bt['Person'].insert((5,'Bing','Digging',None), ('id','name','hobby','Address'))

bt.create_table("FishingClub")
bt['FishingClub'].insert({'FirstName':'Ajes','LastName':'Freeman','Membership':'Active'})
bt['FishingClub'].insert({'FirstName':'John','LastName':'Smith','Membership':'Active'})
bt['FishingClub'].insert({'FirstName':'Jane','LastName':'Brown','Membership':'Active'})
bt['FishingClub'].insert({'FirstName':'Nutmeg','LastName':'Spaniel','Membership':'Active'})
bt['FishingClub'].insert({'FirstName':'Zekey','LastName':'Pokey','Membership':'Active'})

Loop your data using iterrows function. This will loop through all the rows one by one in a Python dict.

for idx, row in bt['Person'].iterrows():
    print(idx, row)

# 1 {'id': 1, 'name': 'John', 'surname': 'Smith', 'address': '1 Station St', 'hobby': None}
# 2 {'id': 2, 'name': 'Jane', 'surname': 'Brown', 'address': '8 Parade Rd', 'hobby': 'Digging'}
# 4 {'id': 3, 'name': 'Okie', 'surname': 'Dokie', 'address': '7 Ocean Rd', 'hobby': None}
# 4 {'id': 4, 'name': 'Maria', 'surname': None, 'address': '7 Heaven Ave', 'hobby': 'Digging'}
# 5 {'id': 5, 'name': 'Bing', 'surname': None, 'address': None, 'hobby': 'Digging'}

If the table is small, you can use print() function to output the records to terminal.

Person.print()
#                           Table: Person
# --------------+---------+-----------+----------------+-----------
#       id      |   name  |  surname  |    address     |   hobby
# --------------+---------+-----------+----------------+-----------
#             1 | John    | Smith     | 1 Station St   | None
#             2 | Jane    | Brown     | 8 Parade Rd    | Digging
#             3 | Okie    | Dokie     | 7 Ocean Rd     | None
#             4 | Maria   | None      | 7 Heaven Ave   | Digging
#             5 | Bing    | None      | None           | Digging
# --------------+---------+-----------+----------------+-----------
# (5 rows)

You should notice that all columns now have been normalised for each row, even though all records have not used all column names during insertion.When the 1st record (idx 0) is inserted, four columns created. id, name, age and address. When insert 4th record is inserted (idx 3), a hobby column added.

Inspect Person table column list. You can also use function table.get_columns() to list all columns.

print(bt['Person'])
# {
#   "name": "Person",
#   "columns": [
#       {"id": 0,"name": "id"},
#       {"id": 1,"name": "name"},
#       {"id": 2,"name": "age"},
#       etc...
# }

Use update function to change the data. The function signature is table.update(column, value, where=None). The value and where parameters can use lambda function argument for smarter expression.

bt['Person'].update('age', 10, where=lambda row: row['name']=='Maria')

Retrieve the row stored at the 3rd index by passing 3 inside the list next to table object.

bt['Person'][3]
# {'id': 4, 'name': 'Maria', 'age': 10, 'address': '7 Heaven Ave', 'hobby': 'Digging'}

Common Functions

We are going to provide some functions that may be needed most when working with Bintang objects.

Bintang.read_excel(wb, sheetnames=None)

Read an Excel file and create Bintang tables. The first row will be assumed as column header. Go to Bintang.Table.read_excel() to read a single sheet and populate the data into created table. Use openpyxl workbook (wb) to read from xlsx, or use xlrd wb to read from xls. Before using openpyxl or xlrd package, you must install the packages. Below is an example on how to install the packge from a terminal.

C:\project_dir>pip install openpyxl
C:\project_dir>pip install xlrd

path:

an excel file path to read from.

sheetname:

a list of sheets that only needed to be read. If not specified all available sheets will be read (default).

from openpyxl import Workbook
...
wb = load_workbook('/path/to/file.xlsx',  read_only=True, data_only=True)
bt.read_excel(wb, sheetnames)

Bintang.read_dict(dict_obj)

Read dictionary object and create a table.

dict_obj:

a python dictionary object

# other module import
# ...
import bintang

# example dict object
dict_obj =  [
         {
             'id': 1,'name': 'John','surname': 'Smith'
         },
         {
             'id': 2,'name': 'Jane','surname': 'Brown'
         }
     ]
bt = bintang.Bintang()
bt.read_dict(dict_obj)
bt['/'].print()
#                     Table: /
#--------------+--------------+--------+-----------
#      /       |      id      |  name  |  surname
#--------------+--------------+--------+-----------
#           0  |           1  |  John  |  Smith
#           1  |           2  |  Jane  |  Brown
#--------------+--------------+--------+-----------
#(2 rows)

Bintang.Table.blookup(lkp_table, on, ret_columns)

Return one or more columns from lookup table.

lkp_table:

lookup table

on:

lookup key tuples

ret_columns:

lookup columns to be returned

# using tables from Example of Usage section above.
bt['Person'].blookup('FishingClub')], \
    [('name','FirstName')], \
    ['Membership'])

# check results
for idx, row in bt['Person'].iterrows(['name','Membership']):
    print(idx, row)

# 0 {'name': 'John', 'Membership': 'Active'}
# 1 {'name': 'Jane', 'Membership': 'Active'}
# 2 {'name': 'Okie', 'Membership': None}
# 3 {'name': 'Maria', 'Membership': None}

We can see only John and Jane got the membership because their names exists in both tables.

Bintang.Table.groupby(columns, drop_none=True, group_count=False, counts=None, sums=None, mins=None, maxs=None, means=None, group_concat=None)

Return grouped rows based upon the value of columns.

columns:

a list of columns that is used to group the data.

drop_none:

if True, to drop/exclude the group if all columns hold None.

group_count:

if True, create row count from group columns.

group_concat:

a column to create group_concat like mysql.

counts:

a list of columns to create count column(s)

sums:

a list of columns to create sum column(s)

mins:

a list of columns to create min column(s)

maxs:

a list of columns to create max column(s)

import bintang
bt = bintang.Bintang()
bt.create_table('Product') # this will be our basis table for grouping
p = bt['Product'] # assign p as the table
p.insert({'id':1, 'brand': 'Shimano', 'class':'rod', 'name':'Extraction','price':299})
p.insert({'id':2, 'brand': 'Shimano', 'class':'rod', 'name':'Zodias Travel','price':399})
p.insert({'id':3, 'brand': 'Ugly Stik', 'class':'rod', 'name':'Balance II','price':63.99})
p.insert({'id':4, 'brand': 'Shimano', 'class':'rod', 'name':'Zodias Travel','price':399})
p.insert({'id':5, 'brand': 'Shimano', 'class':'reel', 'sub class': 'spinning', 'name':'Sedona F1','price':99.00})
p.insert({'id':6, 'brand': 'Shimano', 'class':'reel', 'sub class':'spinning', 'name':'FX Series 4000','price':54.99})

grouped = p.groupby(['brand', 'class'], group_count=True)

grouped.print()
#              Table: grouped
# -------------+---------+---------------
#     brand    |  class  |  group_count
# -------------+---------+---------------
#  Shimano     | rod     |             3
#  Ugly Stik   | rod     |             1
#  Shimano     | reel    |             2
# -------------+---------+---------------
# (3 rows)

grouped = p.groupby(['brand'], group_concat='id', sums=['price']) # another example

grouped.print()
#                     Table: grouped
# -------------+-------------------+-------------------
#     brand    |    group_concat   |     sum_price
# -------------+-------------------+-------------------
#  Shimano     |   [1, 2, 4, 5, 6] |           1250.99
#  Ugly Stik   |               [3] |             63.99
# -------------+-------------------+-------------------
# (2 rows)

Bintang.Table.innerjoin(right_table, on, into=None, out_leftcolumns=None, out_rightcolumns=None)

Return a new table from an inner join operation.

right_table:

name of right table or the second table.

on:

a list of pair columns used for the join.

into:

a new table name to hold the result.

out_leftcolumns:

columns output from left table. If not specified then it will return all columns.

out_rightcolumns:

columns outpout from right table. If not specified then it will return all columns.

bt.create_table('Person') # This will be a left table
# insert some record here. See insert below for an example.
# ...

bt.create_table('FishingClub') # this will be a right table
# insert some records here. See insert below for an example.
# ...

# let's match the two tables for their firt name and last name.
res = bt.innerjoin('Person'                                       # left table
                  ,'FishingClub'                                  # right table
                  ,[('name','FirstName'), ('surname','LastName')] # on
                  ,into='Fisherman'
                  ,out_lcolumns=['name','address']
                  ,out_rcolumns=['Membership']
                  )

# check the result. you can loop through 'Fisherman' or res.
for idx, row in bt['Fisherman'].iterrows():
   print(idx, row)

Bintang.Table.insert(dict_or_columns, values=None)

Insert a record into a table.

dict_or_columns:

dict or list/tuple of column.

values:

if the dict_or_columns is a list/tuple of column, then values is a list/tuple of values (in the same order as in the columns)

bt.create_table('Person')
p = bt.get_table('Person') # get table object for Person
# insert data directly from table object instead throug bt object.
p.insert({'id':1,'name':'John','surname':'Smith','address':'1 Station St'})
p.insert({'id':2,'name':'Jane','surname':'Brown','hobby':'Digging','address':'8 Parade Rd'})
p.insert({'id':3,'name':'Okie','surname':'Dokie','address':'7 Ocean Rd'})
p.insert({'id':4,'name':'Maria','surname':'Digging','address':'7 Heaven Ave'})
p.insert({'id':5,'name':'Bing','surname':'Digging', 'address':None})

bt.create_table('FishingClub')
# lets make a list of columns so we can pass it to insert.
columns = ['FirstName','LastName','Membership']
bt['FishingClub'].insert({'FirstName':'Ajes','LastName':'Freeman','Membership':'Active'})
bt['FishingClub'].insert({'FirstName':'John','LastName':'Smith','Membership':'Active'})
bt['FishingClub'].insert({'FirstName':'John','LastName':'Brown','Membership':'Active'})
bt['FishingClub'].insert({'FirstName':'Okie','LastName':'Dokie','Membership':'Active'})
bt['FishingClub'].insert({'FirstName':'Zekey','LastName':'Pokey','Membership':'Active'})


bt.create_table("Product")
prod = bt['Product']
# example of assigning a dictionary argument for record parameter.
prod.insert({'id':1, 'name':'Hook','price':1.60})
prod.insert({'id':2, 'name':'Sinker','price':1.20})
prod.insert({'id':3, 'name':'Reels','price':75})

Bintang.Table.iterrows(columns=None, row_type=’dict’)

Loop through Bintang table’s rows and yield index and row. Row can be called out as dict (default) or list.

columns:

a list of columns to output. If None, will output all columns.

row_type:

either ‘dict’ (default) or ‘list’.

for idx, row in bt['tablename'].iterrows():
    # do something with idx or row
    print(idx, row)

Bintang.Table.read_csv(path, delimiter=’,’, quotechar=’”’, header_row=1)

Read csv file and populate its records to table.

path:

a csv file path to read from.

delimiter:

field seperator, by default it’ll accept a comma character.

header_row:

the row number that contains column name or label.

## example data in  csv file
# "id","name","surname","address","hobby"
# "1","John","Smith","1 Station St",""
# "2","Jane","Brown","8 Parade Rd","Digging"

bt.create_table('Person')
bt['Person'].read('/path/to/file.csv')
bt['Person'].print()

#                          Table: Person
# ------+---------+-----------+----------------+-----------
#   id  |   name  |  surname  |    address     |   hobby
# ------+---------+-----------+----------------+-----------
#  1    | John    | Smith     | 1 Station St   |
#  2    | Jane    | Brown     | 8 Parade Rd    | Digging
# ------+---------+-----------+----------------+-----------
# (2 rows)

Bintang.Table.read_excel(wb, sheetname, header_row=1)

Read an Excel file into Bintang table. Use openpyxl workbook (wb) to read from xlsx, or use xlrd wb to read from xls. Before using openpyxl or xlrd package, you must install the packages. Below is an example on how to install the packge from a terminal.

C:\project_dir>pip install openpyxl
C:\project_dir>pip install xlrd

wb:

a workbook object

sheetname:

the sheetname to read from.

header_row:

the row number that contains column name or label.

### to read from xlsx
from openpyxl import load_workbook
...
wb = load_workbook('/path/to/file.xlsx', read_only=True, data_only=True)
bt.create_table('Person')
bt['Person'].read_excel(wb, 'Sheet1')


### to read from xls
import xlrd
...
wb = xlrd.open_workbook('/path/to/file.xlsx')
bt.create_table('Person')
bt['Person'].read_excel(wb, 'Sheet1')

Bintang.Table.read_sql(conn, sql_str=None, params=None)

Read sql table/statement and populate the data to Bintang table. If you need to read sql table/statement without populating data then you must use create_sql_linked_table function. This function requires pyodbc or psycopg (postgresql specific) connection, therefore you must install the required package. Below is an example to install the package from a terminal.

C:\project_dir>pip install pyodbc
C:\project_dir>pip install psycopg

conn:

pyodbc database connection

sql_str:

sql query, if none it will select * from a same sql table name.

params:

sql parameters

import bintang
import pyodbc

# connect to sql server
conn_str = "DRIVER={ODBC Driver 17 for SQL Server};SERVER=localhost;PORT=1443;DATABASE=test;Trusted_Connection=yes;"
conn = pyodbc.connect(conn_str)
sql_str = "SELECT * FROM Person WHERE LastName=?"
params = ('Dokey')

bt = bintang.Bintang()
bt.create_table('Person')
bt['Person'].read_sql(conn, sql_str, params)

for idx, row in bt['Person'].iterrows():
    print(idx, row)
    # would print {'ID': 3, 'FirstName': 'Okie', 'LastName': 'Dokey', 'address': '7 Ocean Rd'}

conn.close()

Bintang.table.to_csv(path, columns=None, index=False, delimiter=’,’, quotechar=’”’, quoting=0)

Write bintang table to a csv file.

path:

a csv file path to write to.

index:

write row index if it sets True.

delimiter:

field seperator

quotechar:

a character to quote the data

quoting:

the csv enum for quoting, csv.QUOTE_MINIMAL or 0, csv.QUOTE_ALL or 1, csv.QUOTE_NONNUMERIC or 2, csv.QUOTE_NONE or 3

Notes: setting quoting parameter properly will provide correct value to be presented in csv even if the value containing a delimiter character.

bt['tablename'].to_csv('/path/to/file.csv')

Bintang.Table.to_excel(wb, path, columns=None, index=False, sheet_title=None)

Write Bintang table to an Excel file. Use openpyxl workbook (wb) to save as xlxs, or xlwt to save as xls. Before using openpyxl or xlwt package, you must install the packages. Below is an example on how to install the packge from a terminal.

C:\project_dir>pip install openpyxl
C:\project_dir>pip install xlwt

path:

an excel file path to write to.

columns:

a list of columns to save, if None then all columns will be saved.

index:

write row index if it sets True.

sheet_title:

the sheet title, if None then table name will be passed.

### to target xlxs
from openpyxl import Workbook  # import a Workbook class
...
wb = Worbook() # create a wb class
bt['tablename'].to_excel(wb, '/path/to/file.xlsx')

### to target xls
from xlwt import Workbook
...
wb = Workbook()
bt['tablename'].to_excel(wb, '/path/to/file.xls')

Bintang.Table.to_json()

This is just a placeholder. Python make it easy when serializing a dict object to JSON. Conversion would be done by built-in json.JSONEncoder(). Here an example of using our to_dict() function then use build-in module json to convert/export dict to JSON.

# other modules here
# ...
import json

# other codes here
# ...

dict_obj = bt['table_name'].to_dict()

# example to serialise dict_obj to json string
json_str = json.dumps(dict_obj)
# use json_str here!
# ...


# example to write dict_obj to a json file
with open ('myfile.json', 'w') as fp:
    json.dump(dict_obj, fp) # this would serialise dict_obj into myfile.json

Bintang.Table.to_sql(conn, table, columns=None, schema=None, method=’prep’, max_rows = 1)

Insert records into sql table. This function requires pyodbc or psycopg (postgresql specific) connection, therefore you must install the required package. Below is an example to install the package from a terminal.

C:\project_dir>pip install pyodbc
C:\project_dir>pip install psycopg

conn:

pyodbc database connection

table:

the table name in the sql database

columns:

If a dictionary then a columns mapping where the key is sql column (destination) and the value is bintang columns (source). If a list, column mapping will be created automatically assuming source columns and destination columns are the same. If not provided it assumes that user wants to insert all the columns from the table.

schema:

the schema name the sql table belongs to.

method:

‘prep’ to use prepared statement (default) or ‘string’ to use sql string. To avoid sql injection, never use string method when the datasource is external or not known.

max_rows:

maximum rows per batch insert. Allowed value would be from 1 to 1000. Insert more then 1 record when using prep require all data in a column to use the same type, otherwise will raise error.

import bintang
import pyodbc

bt = bintang.Bintang()
bt.create_table('Person')
person = bt.get_table('Person')
person.insert({'id':1,'name':'John','surname':'Smith','address':'1 Station St'})
person.insert({'id':2,'name':'Jane','surname':'Brown','hobby':'Digging','address':'8 Parade Rd'})
person.insert({'id':3,'name':'Okie','surname':'Dokie','address':'7 Ocean Rd'})
person.insert({'id':4,'name':'Maria','surname':'Digging','address':'7 Heaven Ave'})
person.insert({'id':5,'name':'Bing','surname':'Digging', 'address':None})

# let's map column ID, FirstName, LastName, Address in database to bintang's Person table.
columns = {'ID':'id', 'FirstName':'name', 'LastName':'surname', 'Address':'address'}
# connect to database
conn = pyodbc.connect("DRIVER={ODBC Driver 17 for SQL Server};SERVER=localhost;PORT=1443;DATABASE=test;Trusted_Connection=yes;")
# send data to sql
ret = person.to_sql(conn, 'Person', columns)
print(f'{ret} record(s) affected.')
conn.commit()
conn.close()

Bintang.Table.validate(into_invalid_table = None)

To validate table according to the provided column’s properties. This function can only validate data type of int, float, bool, str, None, datetime.date and datetime.datime.

into_invalid_table:

if provided then invalid table will be created with error messages

import bintang
bt = bintang.Bintang()
bt.create_table('Product')
p = bt['Product']
p.add_column('id', data_type='int', min_value=1, required=True)
p.add_column('name', data_type='str', min_length=1, max_length=20)
p.add_column('price', data_type='float', min_value=0)
p.add_column('order_date', data_type='date', max_value=datetime.date(2025,12,31))

p.insert({'id':1, 'name':'Hook','price':'1.60', 'order_date':'2025-07-01'})
p.insert({'id':'', 'name':'Sinker','price':1.20})
p.insert({'id':'3', 'name':'Reels  ','price':15.50})
p.insert({'id':4, 'name':None, 'price':20, 'order_date': '2026-07-01'})
p.insert({'id':'5t', 'name':'Bait','price':20})
p.insert({'id':6, 'name':'Bait has very long name','price':5.50})

# the backend process
for idx, results in p.valrows():
   print(idx, results)
# 1 ((10, 1, True, None), (11, 'Hook', True, None), (12, 1.6, True, None), (13, datetime.date(2025, 7, 1), True, None))
# 2 ((10, None, False, 'column is required but value is None'), (11, 'Sinker', True, None), (12, 1.2, True, None), (12, 1.2, True, None))
# 3 ((10, 3, True, None), (11, 'Reels', True, None), (12, 15.5, True, None), (12, 15.5, True, None))
# 4 ((10, 4, True, None), (10, 4, True, None), (12, 20.0, True, None), (13, datetime.date(2026, 7, 1), False, 'value is above the maximum allowed value 2025-12-31'))
# 5 ((10, '5t', False, "ValueError: could not convert string to float: '5t'"), (11, 'Bait', True, None), (12, 20.0, True, None), (12, 20.0, True, None))
# 6 ((10, 6, True, None), (11, 'Bait has very long name', False, 'value has length 23 which is out of allowed range [1, 20]'), (12, 5.5, True, None), (12, 5.5, True, None))
# 7 ((10, 7, True, None), (11, 'thread', True, None), (11, 'thread', True, None), (11, 'thread', True, None))

# run the high level function
p.validate('Product_Bad_Data')

print('\nthe rows after validation')
for idx, row in p.iterrows():
   print(idx, row)

# 1 {'id': 1, 'name': 'Hook', 'price': 1.6, 'order_date': datetime.date(2025, 7, 1)}
# 3 {'id': 3, 'name': 'Reels', 'price': 15.5, 'order_date': None}

print('\ninvalid rows from table Product_Bad_Data')
for idx, row in bt['Product_Bad_Data'].iterrows():
   print(idx, row)

# 2 {'id': '', 'name': 'Sinker', 'price': 1.2, 'order_date': None, 'invalid_idx': 2, 'error_msg': 'column id - column is required but value is None'}
# 4 {'id': 4, 'name': None, 'price': 20, 'order_date': '2026-07-01', 'invalid_idx': 4, 'error_msg': 'column order_date - value is above the maximum allowed value 2025-12-31'}
# 5 {'id': '5t', 'name': 'Bait', 'price': 20, 'order_date': None, 'invalid_idx': 5, 'error_msg': "column id - ValueError: could not convert string to float: '5t'"}
# 6 {'id': 6, 'name': 'Bait has very long name', 'price': 5.5, 'order_date': None, 'invalid_idx': 6, 'error_msg': 'column name - value has length 23 which is out of allowed range [1, 20]

Other Functions/attributes

Bintang.add_table(table_object)

Add a table to Bintang object. Think Bintang is a container of tables.

table_object:

table object is a table created from create_table function.

Bintang.copy_table(source_tablename, destination_tablename)

Copy a table

source_tablename:

an existing table name from which copy will be made

destination_tablename:

a new table name as the result of the copy

Bintang.create_table(name, columns=None)

Create a table inside Bintang object

name:

string to name the table

columns:

a list of columns. Bintang can create columns during record insertion (dynamic schema effect).

Bintang.drop_table(name)

Drop table from tables container.

name:

table name

bt.drop_table(name)

Bintang.get_table(name)

Return a table object from Bintang object.

name:

table name

# assume bt is a Bintang object
p = bt.get_table('Person') # get Person table object
print(p) # print Person table object
# {
#   "name": "Person",
#   "columns": [
#       {"id": 0,"name": "id"},
#       {"id": 1,"name": "name"},
#       {"id": 2,"name": "age"},
#       etc...
# }

Bintang.get_tables()

return a list of table’s name.

# assume bt is a Bintang object
tables = bt.get_tables()

Bintang.name

To rename Bintang object name can be done through normal assignment.

import bintang
bt = bintang.Bintang('my db')
bt.name = 'your db' # change name from 'my db' to 'your db'

Bintang.Table.add_column(name, data_type=None, column_size=None, min_value=None, max_value=None, min_length=None, max_length=None, required=False)

Add a new column to table. Note that Bintang can also create columns during record insertion (dynamic schema effect).

column:

a string of column name

data_type:

python data type eg. str, int, float

column_size:

string length if data_type is a str

min_value:

minimum value if data_type is a number

max_value:

maximum value if data_type is a number

min_length:

minimum length if data_type is a str

max_length:

maximum length if data_type is a str

required:

boolean value to indicate if the column is required (default is False)

data_type and column_size parameters are used for generating sql table and not used for presenting the data at the moment. min_value, max_value, min_length, max_length and required parameters are used for validating the data when validation function is called. See Bintang.Table.validate() for more details.

Bintang.Table.add_or_update_column(name, data_type=None, column_size=None, min_value=None, max_value=None, min_length=None, max_length=None, required=False)

Add a new column to table or update the column if it already exists. Note that Bintang can also create columns during record insertion (dynamic schema effect). see add_column() for the meaning of the parameters.

Bintang.Table.cmprows(lkp_table, on=None, min_matches=1, find_all=True)

Compare rows from current table against lkp_table and yield matching result (if any). blookup function use this function internally to find the matching rows.

lkp_table:

lookup table aka ‘right side’ table

on:

a list of pair columns used for the comparison. If None, will compare all columns that exist in both tables.

min_matches:

minimum number of matched columns to consider as a match. You should use this when on is not specified.

find_all:

if True, will compare all rows, otherwise will stop at the first match.

# using tables from Example of Usage section above.
for lidx, results in bt['Person'].cmprows('FishingClub'
                                     ,on = [('name', 'FirstName'), ('surname', 'LastName')]
                                     ,find_all = False
                                     ):
    # do something with results
    print(lidx, results)

# 1 [(2, ((11, 11), (12, 12)))] # 1 =lidx, 2 = idx from the lookup table which row matches the condition specified by the 'on'
# 2 [(3, ((11, 11), (12, 12)))] # 11,11 and 12,12 the coresponding column ids for columns specified by 'on'

Bintang.Table.fuzzy_cmprows(lkp_table, on: list[tuple]=None, min_ratio=0.70, min_matches=1, find_all=True)

compare row by using fuzzy matching from current table against lkp_table and yield matching result (if any). It’s powered by Python’s class difflib.SequenceMatcher, or https://github.com/rapidfuzz/RapidFuzz if it’s installed.

lkp_table:

lookup table aka ‘right side’ table

on:

a list of pair columns used for the comparison. If None, will compare all columns that exist in both tables.

min_ratios:

minimum ratio for matching. You should use this wehn on is not specified

min_matches:

minimum number of matched columns to consider as a match. You should use this when on is not specified.

find_all:

if True, will compare all rows, otherwise will stop at the first match.

import bintang
bt = bintang.Bintang()
bt.create_table("Person")
bt.get_table("Person")
bt['Person'].insert(['id','name','surname','address'], [1,'John','Smith','1 Station St'])
bt['Person'].insert(['id','name','surname','hobby','address'], [2,'Jane','Brown','Digging','8 Parade Rd'])
bt['Person'].insert(['id','name','surname','Address'], [3,'Okie','Dokie','7 Ocean Rd'])
bt['Person'].insert(('id','name','hobby','Address'), (4,'Maria','Digging','7 Heaven Ave'))

bt.create_table("FishingClub")
bt['FishingClub'].insert(['id', 'FirstName','LastName','Membership'], [1, 'Ajes','Freeman','Active'])
bt['FishingClub'].insert(['id', 'FirstName','LastName','Membership'], [2, 'Jhon','Smith','Active'])
bt['FishingClub'].insert(['id', 'FirstName','LastName','Membership'], [3, 'Jane','brown','Active'])
bt['FishingClub'].insert(['id', 'FirstName','LastName','Membership'], [4, 'Jen','Bron','Active'])
bt['FishingClub'].insert(['id', 'FirstName','LastName','Membership'], [5, 'Nutmeg','Spaniel','Active'])

print('\nfuzzy compare rows using specific columns')
for lidx, results in bt['Person'].fuzzy_cmprows(
                  'FishingClub'
                  ,on=[
                        ('name', 'FirstName', 0.5)
                        ,('surname', 'LastName', 0.5)
                        ]
                  , find_all=True
                  ):
   # do something
   print(lidx, results)

# 1 [(2, ((11, 11, 0.75), (12, 12, 1.0)))]
# 2 [(3, ((11, 11, 1.0), (12, 12, 1.0))), (4, ((11, 11, 0.5714), (12, 12, 0.8889)))]

print('\nfuzzy compare rows using all columns')
for lidx, results in bt['Person'].fuzzy_cmprows(
                  'FishingClub'
                  ,min_ratio = 0.5
                  ,find_all = True
                  ):
   # do something
   print(lidx, results)

# 1 [(2, ((11, 11, 0.75), (12, 12, 1.0))), (4, ((11, 11, 0.5714), (11, 12, 0.5))), (1, ((10, 10, 1.0),)), (3, ((11, 11, 0.5),))]
# 2 [(3, ((11, 11, 1.0), (12, 12, 1.0))), (2, ((10, 10, 1.0), (11, 11, 0.5))), (4, ((11, 11, 0.5714), (12, 12, 0.8889))), (5, ((11, 12, 0.5455),)), (1, ((11, 11, 0.5),))]
# 3 [(3, ((10, 10, 1.0),))]
# 4 [(4, ((10, 10, 1.0),))]

Bintang.Table.delete(where)

To delete row(s) that meets where conditions.

where:

a lambda expression

# assume p is a Person table
p.delete(lambda row: row['name'].lower()=='john')

Notes: lambda is case-sensitive.

Bintang.Table.delete_row(index)

To delete the row at index.

index:

row index

Bintang.Table.drop_column(name)

Drop a column from a table.

column:

a string of column name

Bintang.Table.get_all_indexes()

Return a list of all row indexes in the table.

Bintang.Table.get_columnid(column)

return column_id

Bintang.Table.get_columnids(columns=None)

return a tuple of column_ids. If columns is not provided then all available columns will be returned.

Bintang.Table.get_columns()

Return a tuple of columns.

Bintang.Table.get_row(index, columns=None, row_type=’dict’)

Return a row at given index.

index:

row index.

columns:

a list of specific columns wanted in the row.

row_type:

row can be in a ‘list’ or ‘dict’ (default)

Bintang.Table.index_exists(index)

Return True if index exists otherwise None.

index:

row index.

Bintang.Table.name

To rename table name, can be done through normal assignment.

bt['my table'].name = 'your table' # change name from 'my table' to 'your table'

Bintang.Table.print(columns=None, show_data_type=False, topn=10)

Print rows to terminal in table format. This would be handy if the table can fit into terminal.

columns:

a list of columns to output. If None, will output all columns (default).

show_data_type:

if True, will output data type.

topn:

to print out only to the topn then break

# assume Person table object exists and has data
Person.print()

Bintang.Table.rename_column(old_column, new_column)

Rename column name.

old_column:

the existing column that will be renamed.

new_column:

new column name.

Bintang.Table.update(column, value, where=None)

To update row(s) in the table

column:

column to be updated. If column does not exist then it will be created (dynamic schema effect).

value:

the value to be set for the row(s). Can also use lambda.

where:

condition in lambda so which row(s) that needs update.

# assume Person table object exists and has records.
Person.update('job', 'fisherman') # this will create job column and set value of the rows to 'fisherman'

# update only row that has name 'John'
Person.update('job', 'fisherman', where=lambda row: row['name']=='John')

# create 'full name' column and populate value with name and surname combined.
bt['Person'].update('full name', lambda row: row['name'] + ' ' + row['surname'])

# one liner conditional expression is common with lambda.
# for instance, if you know there is None in surname then you want to resolve the full name as name.
bt['Person'].update('full name', lambda row: row['name'] if row['surname'] is None else row['name'] + ' ' + row['surname'])

Bintang.Table.update_column(name, data_type=None, column_size=None, ordinal_position=None, min_value=None, max_value=None, min_length=None, max_length=None, required=False)

To update column’s attributes, eg. data_type, column_size and ordinal_position.

name:

the column name

data_type:

python data type eg. str, int, float

column_size:

string length if data_type is a str

ordinal_position:

integer for column order.

min_value:

minimum value if data_type is a number

max_value:

maximum value if data_type is a number

min_length:

minimum length if data_type is a str

max_length:

maximum length if data_type is a str

required:

boolean value to indicate if the column is required (default is False)

Note: At the moment data_type and column_size are used for generating sql table and not used for presenting the data. min_value, max_value, min_length, max_length and required parameters are used for validating the data when validation function is called. See Bintang.Table.validate() for more details.

Bintang.Table.update_row(index, column, value)

To update the row at idx. So only one row will be affected.

index:

row index

column:

which column will be updated

value:

new value

Special Functions

These functions below create linked tables that read data directly from the source only when needed. Therefore these tables do not hold any data in memory and adding/deleting column or records are not allowed.

Bintang.create_csv_linked_table(name, filepath, delimiter=’,’, quotechar=’”’, header_row=1)

Store csv file path and csv attributes when the function gets called. It’ll read the data directly from the csv file later only when needed. This function will not create in memory table therefore adding/delete column or records are not allowed. This table is suitable for extracting ‘big’ data from a csv file that is beyond memory capacity and upload it to a SQL database. Use read_csv function if data manipulation is required.

This function requires pyodbc or psycopg (postgresql specific) connection, therefore you must install the required package. Below is an example to install the package from a terminal.

Read csv file and populate its records to table.

name:

linked table name to be created

filepath:

a csv file path to read from.

delimiter:

field seperator, by default it’ll accept a comma character.

quotechar:

a character to quote the data

header_row:

the row number that contains column name or label.

from bintang import Bintang
bt = Bintang()
bt.create_csv_linked_table('Person', '/path/to/file.csv')
## upload to sql database
# ... <define sql connection here> ...
bt['Person'].to_sql(conn, 'PersonTableInSQL')

Bintang.create_sql_linked_table(name, conn, sql_str=None, params=None)

Store sql connection and sql table/statement. It’ll read the data directly from the sql database later only when needed. This function will not create in memory table therefore adding/delete column or records are not allowed. This table is suitable for extracting ‘big’ data from a DB that is beyond memory capacity and dump it to a flat file like csv. Use read_sql function if data manipulation is required.

This function requires pyodbc or psycopg (postgresql specific) connection, therefore you must install the required package. Below is an example to install the package from a terminal.

C:\project_dir>pip install pyodbc
C:\project_dir>pip install psycopg

name:

linked table name to be created

conn:

pyodbc database connection

sql_str:

sql query, if none it will select * from table_name, assuming the table name exists in the database.

params:

sql parameters

import bintang
import pyodbc

# connect to sql server
conn_str = "DRIVER={ODBC Driver 17 for SQL Server};SERVER=localhost;PORT=1443;DATABASE=test;Trusted_Connection=yes;"
conn = pyodbc.connect(conn_str)
sql_str = "SELECT * FROM Person WHERE LastName=?"
params = ('Dokey')

bt = bintang.Bintang()
bt.create_linked_table('Person', conn, sql_str, params=params)

for idx, row in bt['Person'].iterrows():
    print(idx, row)
    # would print
    # 1 {'ID': 3, 'FirstName': 'Okie', 'LastName': 'Dokey', 'address': '7 Ocean Rd'}
    # ...
    # if you want to return your own index/rownum, pass that column to iterrows' rowid parameter, for eg. rowid='yourRownumCol'
    # please note that this will only work for sql data source.

conn.close()

Changelog

v0.2.17 (2026-03-14)

• Implemented automated versioning using setuptools_scm.

• Added GitHub Actions workflow for automated PyPI publishing.

• Updated README with PyPI and Build Status badges.