address_list = {'北京', '上海', '深圳', '广州', '长沙', '成都', '吉林'}
conn = psycopg2.connect(database="test", user="test", password="test", host="127.0.0.1", port="5433")
print("Opened database successfully")
cur = conn.cursor()
cur.execute('''CREATE TABLE COMPANY
(ID INT PRIMARY KEY NOT NULL,
NAME TEXT NOT NULL,
AGE INT NOT NULL,
ADDRESS CHAR(50),
SALARY REAL);''')
print("Table created successfully")
conn.commit()
for i in range(1, 20000):
# 生成5位随机字符串
name = ''.join(random.sample(string.ascii_letters + string.digits, 5))
age = random.randint(18, 80)
address = random.sample(address_list, 1)[0]
salary = random.randrange(5000, 100000)
cur.execute(f"INSERT INTO COMPANY (ID, NAME, AGE, ADDRESS, SALARY) "
f"VALUES ({++i}, '{name}', {age}, '{address}', {salary} )")
conn.commit()
print("Records created successfully")
conn.close()
二、执行结果
1. 执行create_data.py文件
E:\Python\Python38\python3.exe F:/IdeaProjects/my-jooq/my-python/create_data.py
Opened database successfully
Table created successfully
Records created successfully
Process finished with exit code 0
三、查看结果
一、python脚本文件1. 创建create_data.py 文件，内容如下#!/usr/bin/python# -*- coding: UTF-8 -*-import stringimport psycopg2import randomaddress_list = {'北京', '上海', '深圳', '广州', '长沙', '成都', '吉林'}conn = psycopg2.connect(database="test", user="test", password="t
#返回
数据
库
连接
def dbcconnect():
conn = pymysql.connect(host='ip', port=3306,
user
='
user
name', passwd='password',db='db')
return conn
其实在
Python
中可以用来
连接
Post
greSQL的模块很多，这里比较推荐psyco
pg
2。psyco
pg
2安装起来非常的简单（pip install psyco
pg
2），这里主要重点介绍下如何使用。
连接
数据
库：
import psyco
pg
2
conn = psyco
pg
2.connect(host=10.100.157.168,
user
=
post
gres,password=
post
gres,database=testdb)
连接
时可用参数：
dbname –
数据
库名称 (dsn
连接
模式)
database –
数据
库名称
import time
import json
from flask import Flask, request, session, redirect, url_for, flash
from flask_redis import FlaskRe...
安装命令： pip install Psyco
pg
2
2进行
连接
conn = psyco
pg
2.connect(database="
数据
库名",
user
="用户名", password="密码", host="ip地址如果是本机就写localhost）",
from psyco
pg
2 import extras as ex
conn = psyco
pg
2.connect(database="test",
user
="
post
gres", password="db12345678", host="localhost", port="5432")
cursor = conn.cursor()
# values 后面直接%s
sql = '''INSERT INTO "public"."
user
"("id", "name...
class
Post
gresConn(object):
def __init__(self, db_conn_config, log_info_file, log_error_file):
self.db_conn_config = db_conn_config
self.log_info_fil.
本教程演示了如何使用Apache Airflow进行工作流程编排。
从
PG
CB网站执行ETL作业。从第一页提取每日报告，清理
数据
并将其存储在
数据
库中。该脚本只会从首页提取新报告；这意味着如果ETL作业已经下载了前几天的
数据
，它将仅下载当天的报告。
etl_airflow
|--etl
| |--Dockerfile
| |--etl.py
| |--requirements.txt
|--.gitignore
|--docker-compose.yml
|--README.md
你可以使用
Python
中的 psyco
pg
2 模块来
连接
和操作
Post
greSQL
数据
库。以下是一个简单的示例，演示如何使用 psyco
pg
2 在
Post
greSQL
数据
库中
插入
数据
：
```
python
import psyco
pg
2
#
连接
到
数据
库
conn = psyco
pg
2.connect(
host="your_host",
database="your_database",
user
="your_
user
name",
password="your_password"
# 创建一个游标对象
cur = conn.cursor()
# 编写 SQL
插入
语句
sql = "INSERT INTO your_table (column1, column2, column3) VALUES (%s, %s, %s)"
#
插入
数据
data = ("value1", "value2", "value3")
cur.execute(sql, data)
# 提交更改
conn.commit()
# 关闭游标和
连接
cur.close()
conn.close()
在这个示例中，我们首先使用 psyco
pg
2.connect() 方法
连接
到
Post
greSQL
数据
库。然后，我们创建一个游标对象，该游标对象可以用于执行 SQL 查询和操作
数据
。接下来，我们编写一个 SQL
插入
语句，将
数据
插入
到指定的
表中
。我们使用 cur.execute() 方法执行 SQL 查询，并将
数据
作为参数传递给该方法。最后，我们调用 conn.commit() 方法提交更改，并关闭游标和
连接
。
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-bom</artifactId>
<version>${project.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
我看dubbo源码里面也没位子引用
Java第一个Gradle项目
开发的小白:
Java第一个Gradle项目
开发的小白:
