Metadata-Version: 2.4
Name: beam-mysql-connector2
Version: 1.9.0
Summary: Apache Beam I/O connector designed for accessing MySQL databases.
Home-page: https://github.com/gnomezgrave/beam-mysql-connector
Download-URL: https://pypi.python.org/pypi/beam-mysql-connector2
Author: gnomezgrave
Author-email: gnomez.grave@gmail.com
License: MIT
Keywords: Updated apache beam mysql connector based on beam-mysql-connector
Classifier: License :: OSI Approved :: MIT License
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Requires-Python: >=3.12
Description-Content-Type: text/markdown
License-File: LICENSE.txt
Requires-Dist: apache-beam>=2.62.0
Requires-Dist: mysql-connector-python>=9.2.0
Dynamic: author
Dynamic: author-email
Dynamic: classifier
Dynamic: description
Dynamic: description-content-type
Dynamic: download-url
Dynamic: home-page
Dynamic: keywords
Dynamic: license
Dynamic: license-file
Dynamic: requires-dist
Dynamic: requires-python
Dynamic: summary

# Beam - MySQL Connector
[![PyPI version](https://badge.fury.io/py/beam-mysql-connector2.svg)](https://badge.fury.io/py/beam-mysql-connector2)
![PyPI - Python Version](https://img.shields.io/pypi/pyversions/beam-mysql-connector2)
[![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT)

Beam - MySQL Connector is an io connector of [Apache Beam](https://beam.apache.org/) to access MySQL databases.

## Installation
```bash
pip install beam-mysql-connector2
```

## Getting Started
- Read From MySQL
```Python
from beam_mysql.connector import splitters
from beam_mysql.connector.io import ReadFromMySQL


read_from_mysql = ReadFromMySQL(
        query="SELECT * FROM test_db.tests;",
        host="localhost",
        database="test_db",
        user="test",
        password="test",
        port=3306,
        splitter=splitters.NoSplitter()  # you can select how to split query for performance
)
```

- Write To MySQL
```Python
from beam_mysql.connector.io import WriteToMySQL


write_to_mysql = WriteToMySQL(
        host="localhost",
        database="test_db",
        table="tests",
        user="test",
        password="test",
        port=3306,
        batch_size=1000,
)
```

## License
MIT License. Please refer to the [LICENSE.txt](https://github.com/esaki01/beam-mysql-connector2/blob/master/LICENSE.txt), for further details.
