"""add_agricultural_table

Revision ID: f4e275af56c7
Revises: 1a82e7aba37b
Create Date: 2025-07-12 01:19:14.039177

"""
from alembic import op
import sqlalchemy as sa


# revision identifiers, used by Alembic.
revision = 'f4e275af56c7'
down_revision = '1a82e7aba37b'
branch_labels = None
depends_on = None


def upgrade():
    """升级数据库到当前版本"""
    # ### commands auto generated by Alembic - please adjust! ###
    op.create_table('agricultural_data',
    sa.Column('ID', sa.Integer(), autoincrement=True, nullable=False),
    sa.Column('county_name', sa.String(length=50), nullable=True, comment='县市名称'),
    sa.Column('crop_sowing_area', sa.Float(), nullable=True, comment='农作物播种面积（公顷）'),
    sa.Column('nitrogen_usage', sa.Float(), nullable=True, comment='氮肥使用量（吨/公顷/年）'),
    sa.Column('phosphorus_usage', sa.Float(), nullable=True, comment='磷肥使用量（吨/公顷/年）'),
    sa.Column('potassium_usage', sa.Float(), nullable=True, comment='钾肥使用量（吨/公顷/年）'),
    sa.Column('compound_usage', sa.Float(), nullable=True, comment='复合肥使用量（吨/公顷/年）'),
    sa.Column('organic_usage', sa.Float(), nullable=True, comment='有机肥使用量（吨/公顷/年）'),
    sa.Column('pesticide_usage', sa.Float(), nullable=True, comment='农药使用量（吨/公顷/年）'),
    sa.Column('farmyard_usage', sa.Float(), nullable=True, comment='农家肥使用量（吨/公顷/年）'),
    sa.Column('plastic_film_usage', sa.Float(), nullable=True, comment='农膜存留量（吨/公顷/年）'),
    sa.Column('nitrogen_cd_flux', sa.Float(), nullable=True, comment='氮肥镉输入通量（g/ha/a）'),
    sa.Column('phosphorus_cd_flux', sa.Float(), nullable=True, comment='磷肥镉输入通量（g/ha/a）'),
    sa.Column('potassium_cd_flux', sa.Float(), nullable=True, comment='钾肥镉输入通量（g/ha/a）'),
    sa.Column('compound_cd_flux', sa.Float(), nullable=True, comment='复合肥镉输入通量（g/ha/a）'),
    sa.Column('organic_cd_flux', sa.Float(), nullable=True, comment='有机肥镉输入通量（g/ha/a）'),
    sa.Column('pesticide_cd_flux', sa.Float(), nullable=True, comment='农药镉输入通量（g/ha/a）'),
    sa.Column('farmyard_cd_flux', sa.Float(), nullable=True, comment='农家肥镉输入通量（g/ha/a）'),
    sa.Column('plastic_film_cd_flux', sa.Float(), nullable=True, comment='农膜镉输入通量（g/ha/a）'),
    sa.Column('total_cd_flux', sa.Float(), nullable=True, comment='总镉输入通量（g/ha/a）'),
    sa.Column('data_year', sa.Integer(), nullable=True, comment='数据年份'),
    sa.PrimaryKeyConstraint('ID')
    )
    # ### end Alembic commands ###


def downgrade():
    """将数据库降级到上一版本"""
    # ### commands auto generated by Alembic - please adjust! ###
    op.drop_table('agricultural_data')
    # ### end Alembic commands ###