Apache Beam是一个用于实现流数据处理和批处理的分布式编程框架。JdbcIO是Beam提供的一种用于连接数据库的IO库，可以通过该库实现从数据库中查询/写入数据。

下面是一个使用JdbcIO连接数据库进行查询的Apache Beam pipeline示例，代码如下：

import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions

options = PipelineOptions()

# 定义一个查询语句
query = "SELECT id, name, age FROM users WHERE age > 18"

# 通过JdbcIO连接数据库进行查询
with beam.Pipeline(options=options) as pipeline:
    result = (
        pipeline
        | "Read Data From Database" >> beam.io.jdbc.ReadFromJdbc(
            driverClassName="com.mysql.jdbc.Driver",
            url="jdbc:mysql://127.0.0.1:3306/test",
            query=query,
            username="root",
            password="",
        )
        | "Print Query Result" >> beam.Map(print)
    )

以上代码用于从mysql数据库中查询年龄大于18岁的用户，并打印查询结果。

需要注意的是，在实际使用中需要根据实际情况进行修改，例如修改数据库连接信息或查询语句。