apis/examples_python/transport9_8py_source.html

가져오기sys

가져오기pyodbc

from게임가져오기GamsWorkspace


GAMS_MODEL ="""

설정

i '통조림 식물'

j '시장';


매개변수

a(i) '경우에 따른 식물 i의 용량'

b(j) '경우에 따라 시장 j의 수요'

d(i,j) '거리(천 마일)';


스칼라 f '1,000마일당 케이스당 달러 단위의 화물' / 90 /;


$if 설정되지 않음 gdxincname $abort '제공된 데이터 파일에 대한 포함 파일 이름 없음'

$gdxIn %gdxincname%

$load i j a b d

$gdxIn


매개변수 c(i,j) '케이스당 수천 달러의 운송 비용';

c(i,j) = f*d(i,j)/1000;


변수

x(i,j) '케이스의 배송 수량'

z '총 운송 비용(수천 달러)';


양수 변수 x;


수식

비용 '목적 함수 정의'

supply(i) '공장 i의 공급 제한을 준수하세요'

demand(j) '시장 j의 수요를 충족';


비용.. z =e= sum((i,j), c(i,j)*x(i,j));


공급(i).. 합계(j, x(i,j)) =l= a(i);


수요(j).. 합계(i, x(i,j)) =g= b(j);


모델 수송 /all/;


z를 최소화하는 lp를 사용하여 전송을 해결합니다.


x.l, x.m 표시;

"""


defread_set(connection, db, query_string, set_name, set_dim, set_exp=""):

    시도해 보세요:

커서 = 연결.cursor()

cursor.execute(query_string)

데이터 = 커서.fetchall()


        iflen(데이터[0]) != set_dim:

            올림예외(

                "select 문의 필드 수가 setDim과 일치하지 않습니다"

            )


i = db.add_set(set_name, set_dim, set_exp)


        for행in데이터:

키 = []

            for키에행:

keys.append(str(key))

i.add_record(키)


    제외예외as예:

        올림예외(

            "오류: 데이터베이스에서 필요한 데이터를 검색하는 데 실패했습니다.\n0".format(

예

            )

        )

    마지막으로:

cursor.close()


defread_parameter(connection, db, query_string, par_name, par_dim, par_exp=""):

    시도해 보세요:

커서 = 연결.cursor()

cursor.execute(query_string)

데이터 = 커서.fetchall()


        iflen(데이터[0]) != par_dim + 1:

            올림예외(

                "select 문의 필드 수가 par_dim+1과 일치하지 않습니다."

            )


a = db.add_parameter(par_name, par_dim, par_exp)


        for행in데이터:

키 = []

            foridxin범위(len(행) - 1):

keys.append(str(row[idx]))

a.add_record(keys).value = 행[par_dim]


    제외예외as예:

        올림예외(

            "오류: 데이터베이스에서 필요한 데이터를 검색하는 데 실패했습니다.\n0".format(

예

            )

        )

    마지막으로:

cursor.close()


defwrite_variable(연결, db, var_name, 열_이름):

    시도해 보세요:

var = db.get_variable(var_name)

        iflen(column_names) != var.dimension:

            올림예외(

                "열 이름의 수가 변수의 차원과 일치하지 않습니다"

            )


커서 = 연결.커서()

        시도해 보세요:

cursor.execute("드롭 테이블 "+ var_name)

connection.commit()

        제외:

            통과

쿼리 ="테이블 생성"+ var_name +"("

        for열in열_이름:

쿼리 += 열 +" varchar(64), "

쿼리 +="레벨 더블)"

cursor.execute(쿼리)

connection.commit()


        용rec에var:

쿼리 =""에 삽입하세요+ var_name +"("

            용열에열_이름:

쿼리 += 열 +", "

쿼리 +="lvl) 값 ("

            for키에rec.keys:

질의 +="'"+ 키 +"', "

쿼리 += str(rec.level) +")"

cursor.execute(쿼리)

connection.commit()


    제외예외으로예:

        올림예외(

            "오류: 데이터베이스에 변수를 쓰는 데 실패했습니다.\n0".format(ex)

        )

    마지막으로:

cursor.close()


defwrite_results(db):

str_access_conn =r"DRIVER=Microsoft Access Driver(*.mdb, *.accdb);DBQ=..\..\..\..\apifiles\Data\transport.accdb"

    시도해 보세요:

연결 = pyodbc.connect(str_access_conn)

    제외예외as예:

        올림예외(

            "오류: 데이터베이스 연결 생성에 실패했습니다. \n0".format(ex)

        )

    # 변수 x의 레벨 쓰기

write_variable(연결, db,"x", ["나", "j"])

connection.close()


defread_from_access(ws):

db = ws.add_database()


    # 데이터베이스에 연결

str_access_conn =r"DRIVER=Microsoft Access Driver(*.mdb, *.accdb);DBQ=..\..\..\..\apifiles\Data\transport.accdb"


    시도:

연결 = pyodbc.connect(str_access_conn)

    제외예외ase:

        올림예외(f"오류: 데이터베이스 연결 생성에 실패했습니다.\ne")


    # 슬롯 세트 읽기

read_set(연결, db,"식물에서 식물 선택", "나", 1,"통조림 공장")

read_set(연결, db,"시장에서 시장 선택", "j", 1,"시장")


    # 슬롯 매개변수 읽기

read_parameter(

연결,

db,

        "공장 선택,공장에서 생산 능력",

        "a",

        1,

        "케이스에 있는 식물 i의 용량",

    )

read_parameter(

연결,

db,

        "시장 선택,시장에서 수요",

        "b",

        1,

        "경우에 따라 시장 j의 수요",

    )

read_parameter(

연결,

db,

        "공장,시장,거리 FROM 거리 선택",

        "d",

        2,

        "수천 마일 단위의 거리",

    )


connection.close()

    반환db


if__name__ =="__main__":

sys_dir = sys.argv[1]iflen(sys.argv) > 1그밖에 없음

work_dir = sys.argv[2]iflen(sys.argv) > 2그밖에 없음

ws = GamsWorkspace(system_directory=sys_dir, Working_directory=work_dir)


    # Access에서 읽어 GamsDatabase를 채웁니다.

db = read_from_access(ws)


    # 작업 실행

작업 = ws.add_job_from_string(GAMS_MODEL)

opt = ws.add_options()

opt.defines["gdxincname"] = db.name

opt.all_model_types ="익스프레스"

job.run(옵션, 데이터베이스=db)


    # 결과를 액세스 파일에 기록

write_results(job.out_db)